fgrpc

type DynamicGrpcCall struct {
	MethodPath string           // e.g. "/Service/Method"
	RequestMsg *dynamic.Message // dynamic protobuf for request
	// contains filtered or unexported fields
}

type GRPCRunnerOptions struct {
	periodic.RunnerOptions
	fhttp.TLSOptions
	Destination        string
	Service            string        // Service to be checked when using gRPC health check
	Profiler           string        // file to save profiles to. defaults to no profiling
	Payload            string        // Payload to be sent for gRPC ping service
	Streams            int           // number of streams. total go routines and data streams will be streams*numthreads.
	Delay              time.Duration // Delay to be sent when using gRPC ping service
	CertOverride       string        // Override the cert virtual host of authority for testing
	AllowInitialErrors bool          // whether initial errors don't cause an abort
	UsePing            bool          // use our own Ping proto for gRPC load instead of standard health check one.
	Metadata           metadata.MD   // input metadata that will be added to the request

	GrpcCompression bool   // enable gRPC compression
	GrpcMethod      string // gRPC method to call (Service/Method)
	// contains filtered or unexported fields
}

type GRPCRunnerResults struct {
	periodic.RunnerResults

	RetCodes    HealthResultMap
	Destination string
	Streams     int
	Ping        bool
	Metadata    metadata.MD
	// contains filtered or unexported fields
}

type HealthResultMap map[string]int64

type PingMessage struct {
	Seq        int64  `protobuf:"varint,1,opt,name=seq" json:"seq,omitempty"`
	Ts         int64  `protobuf:"varint,2,opt,name=ts" json:"ts,omitempty"`
	Payload    string `protobuf:"bytes,3,opt,name=payload" json:"payload,omitempty"`
	DelayNanos int64  `protobuf:"varint,4,opt,name=delayNanos" json:"delayNanos,omitempty"`
}

type PingServerClient interface {
	Ping(ctx context.Context, in *PingMessage, opts ...grpc.CallOption) (*PingMessage, error)
}

type PingServerServer interface {
	Ping(context.Context, *PingMessage) (*PingMessage, error)
}