lancerlogstream

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"`
	PoolConfig      *ConnPoolConfig `tome:"poolConfig"`
}

func (*Config) ConfigValidate

func (c *Config) ConfigValidate() error

type ConnPoolConfig

type ConnPoolConfig struct {
	Name        string         `tome:"name"`
	AddrList    []string       `tome:"addrList"`
	DialTimeout xtime.Duration `tome:"dialTimeout"`
	IdleTimeout xtime.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
}