lancergrpc

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"`
}

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"`
}

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

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