util

Documentation

Index

• func ArgsToCommand(args [][]byte) string
• func CommandToArgs(cmd string) [][]byte
• func EnvGet(key, fallback string) string
• func Message(b []byte) []byte
• func MessageArray(array [][]byte) []byte
• func MessageError(s string) []byte
• func MessageInt(i int64) []byte
• func MessageNull() []byte
• func MessageOK() []byte
• func MessageString(s string) []byte
• type StreamBus
  • func NewStreamBus(size int) *StreamBus
  • func (w *StreamBus) Close() error
  • func (w *StreamBus) Read() <-chan []byte
  • func (w *StreamBus) Write(buf []byte) (int, error)

Functions

func ArgsToCommand

func ArgsToCommand(args [][]byte) string

func CommandToArgs

func CommandToArgs(cmd string) [][]byte

func EnvGet

func EnvGet(key, fallback string) string

func Message

func Message(b []byte) []byte

func MessageArray

func MessageArray(array [][]byte) []byte

func MessageError

func MessageError(s string) []byte

func MessageInt

func MessageInt(i int64) []byte

func MessageNull

func MessageNull() []byte

func MessageOK

func MessageOK() []byte

func MessageString

func MessageString(s string) []byte

Types

type StreamBus

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

func NewStreamBus

func NewStreamBus(size int) *StreamBus

func (*StreamBus) Close

func (w *StreamBus) Close() error

func (*StreamBus) Read

func (w *StreamBus) Read() <-chan []byte

func (*StreamBus) Write

func (w *StreamBus) Write(buf []byte) (int, error)