Versions in this module Expand all Collapse all v0 v0.1.2 Oct 28, 2024 Changes in this version + const DEFAULT_QUEUE_SIZE + const LWES_TYPE_BOOLEAN + const LWES_TYPE_BOOLEAN_ARRAY + const LWES_TYPE_BYTE + const LWES_TYPE_BYTE_ARRAY + const LWES_TYPE_DOUBLE + const LWES_TYPE_DOUBLE_ARRAY + const LWES_TYPE_FLOAT + const LWES_TYPE_FLOAT_ARRAY + const LWES_TYPE_INT_16 + const LWES_TYPE_INT_16_ARRAY + const LWES_TYPE_INT_32 + const LWES_TYPE_INT_32_ARRAY + const LWES_TYPE_INT_64 + const LWES_TYPE_INT_64_ARRAY + const LWES_TYPE_IP_ADDR + const LWES_TYPE_IP_ADDR_ARRAY + const LWES_TYPE_LONG_STRING + const LWES_TYPE_N_BOOLEAN_ARRAY + const LWES_TYPE_N_BYTE_ARRAY + const LWES_TYPE_N_DOUBLE_ARRAY + const LWES_TYPE_N_FLOAT_ARRAY + const LWES_TYPE_N_INT_16_ARRAY + const LWES_TYPE_N_INT_32_ARRAY + const LWES_TYPE_N_INT_64_ARRAY + const LWES_TYPE_N_STRING_ARRAY + const LWES_TYPE_N_U_INT_16_ARRAY + const LWES_TYPE_N_U_INT_32_ARRAY + const LWES_TYPE_N_U_INT_64_ARRAY + const LWES_TYPE_STRING + const LWES_TYPE_STRING_ARRAY + const LWES_TYPE_UNDEFINED + const LWES_TYPE_U_INT_16 + const LWES_TYPE_U_INT_16_ARRAY + const LWES_TYPE_U_INT_32 + const LWES_TYPE_U_INT_32_ARRAY + const LWES_TYPE_U_INT_64 + const LWES_TYPE_U_INT_64_ARRAY + const MAX_MSG_SIZE + const MAX_PACKET_SIZE + const SO_RCVBUF_SIZE + func Marshal(v encoding.BinaryMarshaler) ([]byte, error) + func NewFixedBuffer(pool *sync.Pool, size int) *readBuf + func Unmarshal(data []byte, v encoding.BinaryUnmarshaler) error + type Emitter struct + func Open(cfg EmitterConfig) *Emitter + func (em *Emitter) Close() + func (em *Emitter) Emit(lwe encoding.BinaryMarshaler) error + type EmitterConfig struct + Servers []struct{} + func (sc *EmitterConfig) ParseFromString(param string) (err error) + type LwesEvent struct + Attrs map[string]interface{} + Name string + func NewLwesEvent(name string) *LwesEvent + func (lwe *LwesEvent) Enumerate(callback func(key string, value interface{}) bool) + func (lwe *LwesEvent) FPrint(w io.Writer) + func (lwe *LwesEvent) MarshalBinary() (buf []byte, err error) + func (lwe *LwesEvent) Set(key string, value interface{}) + func (lwe *LwesEvent) Size() int + func (lwe *LwesEvent) UnmarshalBinary(data []byte) error + type Server interface + Addr func() net.Addr + DataChan func() <-chan *readBuf + EnableMetricsReport func(time.Duration, func(string, interface{})) + IsServing func() bool + Serve func() + Stop func() + Wait func() + WaitLwesMode func(num_workers int) <-chan *LwesEvent + func Listen(multi_addrport string) (Server, error) v0.1.0 Oct 28, 2024
Go to main page