utils

package module

v0.1.14 Latest Latest Go to latest Published: Oct 22, 2020 License: MIT Imports: 13 Imported by: 0

Details

Unix Domain Socket utils

This section is empty.

This section is empty.

func ConnectSocket(address string, interval, deadline time.Duration) (*net.UnixConn, error)

sock, err := uds.ConnectSocket("/env/example.sock", time.Second*1, time.Second*5)

sock.Write(msg)

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

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

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

listener, err := uds.OpenSocket("/env/example.sock")

type Config struct {
	Instances map[string]Instance
	Producers map[string]Producer
	Consumers map[string]Consumer
	Params    map[string]interface{}
}

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

Parse flow.toml config

use CONFIG_PATH env var if no parameters given

type Consumer struct {
	ID      string
	Produce string
	Topic   string
	Address string
	Params  map[string]interface{}
}

type Header struct {
	ConsumerID [16]byte
	ProducerID [16]byte
	DataLength uint32
}

type Instance struct {
	ID      string
	Listen  string
	Produce string
	Params  map[string]interface{}
}

type Message struct {
	Header Header
	Data   []byte
}

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

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

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

type Producer struct {
	ID      string
	Listen  string
	Produce string
	Topic   string
	Address string
	Params  map[string]interface{}
}