lancergrpc

Documentation

Index

• Variables
• func DecodeConfig(md toml.MetaData, primValue toml.Primitive) (c interface{}, err error)
• func NewLancer(ctx context.Context, config interface{}) (output.Output, error)
• type Config
  • func (c *Config) ConfigValidate() error
• type ConnPoolConfig
  • func (c *ConnPoolConfig) ConfigValidate() error
• type Lancer
  • func (l *Lancer) InputChan() chan *event.ProcessorEvent
  • func (l *Lancer) Run() (err error)
  • func (l *Lancer) Stop()
• type LancerBufConn

Variables

var (
	ErrAddrListNil = errors.New("addrList can't be nil")
	ErrPoolSize    = errors.New("Pool size should be no greater then length of addr list")
)

Functions

func DecodeConfig

func DecodeConfig(md toml.MetaData, primValue toml.Primitive) (c interface{}, err error)

func NewLancer

func NewLancer(ctx context.Context, config interface{}) (output.Output, error)

Types

type Config

type Config struct {
	Local                bool                `tome:"local"`
	Name                 string              `tome:"name"`
	AggrSize             int                 `tome:"aggrSize"`
	SendConcurrency      int                 `tome:"sendConcurrency"`
	CacheConfig          *file.Config        `tome:"cacheConfig"`
	LancerGateway        *streamEvent.Config `tome:"lancerGateway"`
	SendBatchSize        int                 `tome:"sendBatchSize"`
	SendBatchNum         int                 `tome:"sendBatchNum"`
	SendBatchTimeout     xtime.Duration      `tome:"sendBatchTimeout"`
	SendFlushInterval    xtime.Duration      `tome:"sendFlushInterval"`
	InitialRetryDuration xtime.Duration      `tome:"initialRetryDuration"`
	MaxRetryDuration     xtime.Duration      `tome:"maxRetryDuration"`
}

func (*Config) ConfigValidate

func (c *Config) ConfigValidate() error

type ConnPoolConfig

type ConnPoolConfig struct {
	Name        string        `tome:"name"`
	AddrList    []string      `tome:"addrList"`
	DialTimeout time.Duration `tome:"dialTimeout"`
	IdleTimeout time.Duration `tome:"idleTimeout"`
	BufSize     int           `tome:"bufSize"`
	PoolSize    int           `tome:"poolSize"`
}

func (*ConnPoolConfig) ConfigValidate

func (c *ConnPoolConfig) ConfigValidate() error

type Lancer

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

func (*Lancer) InputChan

func (l *Lancer) InputChan() chan *event.ProcessorEvent

func (*Lancer) Run

func (l *Lancer) Run() (err error)

func (*Lancer) Stop

func (l *Lancer) Stop()

type LancerBufConn

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