utils

README

uds

Unix Domain Socket utils

Documentation

Index

• func ConnectSocket(address string, interval, deadline time.Duration) (*net.UnixConn, error)
• func Decrypt(ciphertext []byte, key []byte) ([]byte, error)
• func Encrypt(plaintext []byte, key []byte) ([]byte, error)
• func OpenSocket(a string) (*net.UnixListener, error)
• type Config
  • func (c *Config) Parse(path ...string) error
• type Consumer
• type Header
• type Instance
• type Message
  • func (m *Message) Decode(c net.Conn) error
  • func (m *Message) Encode() ([]byte, error)
  • func (m *Message) ForwardMessage(c *net.UnixConn) error
• type Producer

Functions

func ConnectSocket

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

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

func Encrypt

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

func OpenSocket

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

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

Types

type Config

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

func (*Config) Parse

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

Parse flow.toml config

use CONFIG_PATH env var if no parameters given

type Consumer

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

type Header

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

type Instance

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

type Message

type Message struct {
	Header Header
	Data   []byte
}

func (*Message) Decode

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

func (*Message) Encode

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

func (*Message) ForwardMessage

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

type Producer

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