client

Jun 4, 2021

Changes in this version

+ const ClientTypeServerless

+ const ClientTypeSource

+ const ClientTypeZipperSender

+ type NegotiationPayload struct

+ AppName string

+ ClientType string

+ type ZipperSenderClient interface

+ Connect func(ip string, port int) (ZipperSenderClient, error)

+ func NewZipperSender(appName string) ZipperSenderClient

May 20, 2021

Changes in this version

+ var SignalAccepted = []byte

+ var SignalFlowSink = []byte

+ var SignalHeartbeat = []byte

+ type ServerlessClient struct

+ func NewServerless(appName string) *ServerlessClient

+ func (c *ServerlessClient) Connect(ip string, port int) (*ServerlessClient, error)

+ func (c *ServerlessClient) Pipe(f func(rxstream rx.RxStream) rx.RxStream)

+ func (c ServerlessClient) Close()

+ type SourceClient struct

+ func NewSource(appName string) *SourceClient

+ func (c *SourceClient) Connect(ip string, port int) (*SourceClient, error)

+ func (c *SourceClient) Write(b []byte) (int, error)

+ func (c SourceClient) Close()