utils

Oct 22, 2020

Changes in this version

type Config

+ func (c *Config) Parse(path ...string) error

Apr 17, 2020

Changes in this version

type Config

+ Params map[string]string

Apr 17, 2020

Changes in this version

type Consumer

+ Params map[string]interface{}

type Instance

+ Params map[string]string

type Producer

+ Params map[string]string

Apr 15, 2020

Changes in this version

+ type Consumer struct

+ Address string

+ ID string

+ Produce string

+ Topic string

+ type Instance struct

+ ID string

+ Listen string

+ Produce string

+ type Producer struct

+ Address string

+ ID string

+ Listen string

+ Produce string

+ Topic string

Apr 13, 2020

Changes in this version

+ func Decrypt(ciphertext []byte, key []byte) ([]byte, error)

+ func Encrypt(plaintext []byte, key []byte) ([]byte, error)

Apr 13, 2020

Changes in this version

type Message

+ func (m Message) ForwardMessage(c *net.UnixConn) error

Apr 13, 2020

Changes in this version

+ func ConnectSocket(address string, delay time.Duration) (*net.UnixConn, error)

+ type Config struct

+ Consumers map[string]consumer

+ Instances map[string]instance

+ Producers map[string]producer

+ func (c Config) Read(path string) error

+ type Header struct

+ ConsumerID [16]byte

+ DataLength uint32

+ ProducerID [16]byte

+ type Message struct

+ Data []byte

+ Header Header

+ func (m Message) Decode(c net.Conn) error

+ func (m Message) Encode() ([]byte, error)

Apr 8, 2020

Changes in this version

+ func Listen(a string, delay time.Duration) (*net.UnixConn, error)

+ func OpenSocket(a string) (*net.UnixListener, error)