lancerlogstream

package
v0.0.0-...-83adff0 Latest Latest
Warning

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

Go to latest
Published: Jul 6, 2020 License: GPL-3.0 Imports: 21 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source
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
}

Jump to

Keyboard shortcuts

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