fgrpc

package
v0.7.1 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Feb 22, 2018 License: Apache-2.0 Imports: 15 Imported by: 5

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

View Source
const (
	// DefaultGRPCPort is the Fortio gRPC server default port number.
	DefaultGRPCPort = "8079"
)

Variables

This section is empty.

Functions

func Dial added in v0.7.0

func Dial(serverAddr string, tls bool) (conn *grpc.ClientConn, err error)

Dial dials grpc either using insecure or using default tls setup. TODO: option to specify certs.

func GRPCDestination added in v0.6.8

func GRPCDestination(dest string) string

GRPCDestination parses dest and returns dest:port based on dest type being a hostname, IP address or hostname/ip:port pair.

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
	Secure      bool   // use tls transport
}

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)
}

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL