grpc

Documentation

Index

• func ConvertGrpcStatus(err error) int
• func MakeGRPCConnect(target string, isTLS bool, dialOptions GrpcDialOptions) (conn *grpc.ClientConn, err error)
• type AnswLogConfig
• type GrpcDialOptions
• type Gun
  • func NewGun(conf GunConfig) *Gun
  • func (g *Gun) Answ(method *desc.MethodDescriptor, message *dynamic.Message, ...)
  • func (g *Gun) AnswLogging(logger *zap.Logger, method *desc.MethodDescriptor, request proto.Message, ...)
  • func (g *Gun) Bind(aggr core.Aggregator, deps core.GunDeps) error
  • func (g *Gun) Shoot(am core.Ammo)
  • func (g *Gun) WarmUp(opts *warmup.Options) (any, error)
• type GunConfig
  • func DefaultGunConfig() GunConfig
• type Sample
• type SharedDeps

Functions

func ConvertGrpcStatus

func ConvertGrpcStatus(err error) int

func MakeGRPCConnect

func MakeGRPCConnect(target string, isTLS bool, dialOptions GrpcDialOptions) (conn *grpc.ClientConn, err error)

Types

type AnswLogConfig

type AnswLogConfig struct {
	Enabled bool   `config:"enabled"`
	Path    string `config:"path"`
	Filter  string `config:"filter" valid:"oneof=all warning error"`
}

type GrpcDialOptions

type GrpcDialOptions struct {
	Authority string        `config:"authority"`
	Timeout   time.Duration `config:"timeout"`
}

type Gun

type Gun struct {
	DebugLog bool
	Conf     GunConfig
	Aggr     core.Aggregator
	core.GunDeps

	Stub     grpcdynamic.Stub
	Services map[string]desc.MethodDescriptor

	AnswLog *zap.Logger
}

func NewGun

func NewGun(conf GunConfig) *Gun

func (*Gun) Answ

func (g *Gun) Answ(method *desc.MethodDescriptor, message *dynamic.Message, metadata map[string]string, out proto.Message, grpcErr error, code int)

func (*Gun) AnswLogging

func (g *Gun) AnswLogging(logger *zap.Logger, method *desc.MethodDescriptor, request proto.Message, metadata map[string]string, response proto.Message, grpcErr error)

func (*Gun) Bind

func (g *Gun) Bind(aggr core.Aggregator, deps core.GunDeps) error

func (*Gun) Shoot

func (g *Gun) Shoot(am core.Ammo)

func (*Gun) WarmUp

func (g *Gun) WarmUp(opts *warmup.Options) (any, error)

type GunConfig

type GunConfig struct {
	Target          string            `validate:"required"`
	ReflectPort     int64             `config:"reflect_port"`
	ReflectMetadata map[string]string `config:"reflect_metadata"`
	Timeout         time.Duration     `config:"timeout"` // grpc request timeout
	TLS             bool              `config:"tls"`
	DialOptions     GrpcDialOptions   `config:"dial_options"`
	AnswLog         AnswLogConfig     `config:"answlog"`
	SharedClient    struct {
		ClientNumber int  `config:"client-number,omitempty"`
		Enabled      bool `config:"enabled"`
	} `config:"shared-client,omitempty"`
}

func DefaultGunConfig

func DefaultGunConfig() GunConfig

type Sample

type Sample struct {
	URL              string
	ShootTimeSeconds float64
}

type SharedDeps

type SharedDeps struct {
	// contains filtered or unexported fields
}