grpc

Documentation

Index

• type AnswLogConfig
• type Gun
  • func NewGun(conf GunConfig) *Gun
  • func (g *Gun) AcceptWarmUpResult(i interface{}) error
  • 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) (interface{}, error)
• type GunConfig
  • func DefaultGunConfig() GunConfig
• type Sample

Types

type AnswLogConfig

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

type Gun

type Gun struct {
	DebugLog bool

	core.GunDeps
	// contains filtered or unexported fields
}

func NewGun

func NewGun(conf GunConfig) *Gun

func (*Gun) AcceptWarmUpResult

func (g *Gun) AcceptWarmUpResult(i interface{}) 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) (interface{}, error)

type GunConfig

type GunConfig struct {
	Target      string          `validate:"required"`
	Timeout     time.Duration   `config:"timeout"` // grpc request timeout
	TLS         bool            `config:"tls"`
	DialOptions grpcDialOptions `config:"dial_options"`
	AnswLog     AnswLogConfig   `config:"answlog"`
}

func DefaultGunConfig

func DefaultGunConfig() GunConfig

type Sample

type Sample struct {
	URL              string
	ShootTimeSeconds float64
}