Documentation
¶
Overview ¶
Package fgrpc is a generated protocol buffer package.
It is generated from these files:
ping.proto
It has these top-level messages:
PingMessage
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func RegisterPingServerServer ¶
func RegisterPingServerServer(s *grpc.Server, srv PingServerServer)
Types ¶
type GRPCRunnerOptions ¶
type GRPCRunnerOptions struct {
periodic.RunnerOptions
Destination string
Service string
Profiler string // file to save profiles to. defaults to no profiling
}
GRPCRunnerOptions includes the base RunnerOptions plus http specific options.
type GRPCRunnerResults ¶
type GRPCRunnerResults struct {
periodic.RunnerResults
RetCodes map[grpc_health_v1.HealthCheckResponse_ServingStatus]int64
// contains filtered or unexported fields
}
GRPCRunnerResults is the aggregated result of an GRPCRunner. Also is the internal type used per thread/goroutine.
func RunGRPCTest ¶
func RunGRPCTest(o *GRPCRunnerOptions) (*GRPCRunnerResults, error)
RunGRPCTest runs an http test and returns the aggregated stats.
func (*GRPCRunnerResults) Run ¶ added in v0.4.2
func (grpcstate *GRPCRunnerResults) Run(t int)
Run exercises GRPC health check at the target QPS. To be set as the Function in RunnerOptions.
type PingMessage ¶
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"`
}
func (*PingMessage) Descriptor ¶
func (*PingMessage) Descriptor() ([]byte, []int)
func (*PingMessage) GetPayload ¶
func (m *PingMessage) GetPayload() string
func (*PingMessage) GetSeq ¶
func (m *PingMessage) GetSeq() int64
func (*PingMessage) GetTs ¶
func (m *PingMessage) GetTs() int64
func (*PingMessage) ProtoMessage ¶
func (*PingMessage) ProtoMessage()
func (*PingMessage) Reset ¶
func (m *PingMessage) Reset()
func (*PingMessage) String ¶
func (m *PingMessage) String() string
type PingServerClient ¶
type PingServerClient interface {
Ping(ctx context.Context, in *PingMessage, opts ...grpc.CallOption) (*PingMessage, error)
}
func NewPingServerClient ¶
func NewPingServerClient(cc *grpc.ClientConn) PingServerClient
type PingServerServer ¶
type PingServerServer interface {
Ping(context.Context, *PingMessage) (*PingMessage, error)
}
Source Files
Click to show internal directories.
Click to hide internal directories.