helpers

func AddETCDNode(etcdAdapter storeadapter.StoreAdapter, key string, value string)

func AddWSSink(receivedChan chan []byte, port string, path string) (*websocket.Conn, <-chan struct{})

func AppKey(appID string) string

func DecodeProtoBufCounterEvent(actual []byte) *events.CounterEvent

func DecodeProtoBufEnvelope(actual []byte) *events.Envelope

func DecodeProtoBufLogMessage(actual []byte) *events.LogMessage

func DialTLS(address, cert, key, ca string) (*tls.Conn, error)

func DrainKey(appID string, drainURL string) string

func MarshalEvent(event events.Event, secret string) []byte

func MarshalProtoBuf(pb proto.Message) []byte

func SendAppLog(appID string, message string, connection net.Conn) error

func SendAppLogTCP(appID string, message string, connection net.Conn) error

func SendEvent(event events.Event, connection net.Conn) error

func SendEventTCP(event events.Event, conn net.Conn) error

func StartEncryptedTCPServer(pathToTCPEchoServer string, syslogDrainAddress string) *gexec.Session

func StartHTTPSServer(pathToHTTPEchoServer string) *gexec.Session

func StartUnencryptedTCPServer(pathToTCPEchoServer string, syslogDrainAddress string) *gexec.Session

func UnmarshalMessage(messageBytes []byte) events.Envelope