client

Mar 6, 2022

Changes in this version

+ const EVENT_IDENTITY

+ const EVENT_SUBSCRIBER_ACK

+ func HandleEvents()

type ClientOptions

+ UrlClipboard bool

type Message

+ func NewMessage(message []byte) (Message, error)

+ func (m Message) MarshalPayload() ([]byte, error)

+ func (m Message) ToSubscriberConnectedMessage() (SubscriberConnectedMessage, error)

+ type SubscriberConnectedMessage struct

+ Connected bool

Mar 4, 2022

Changes in this version

+ const DEFAULT_DOMAIN

+ const DEFAULT_ENVIRONMENT

+ const DEFAULT_LOG_LEVEL

+ func HandleIncomingMessages(connection *websocket.Conn)

+ func HandleSendEvents(input chan string, connection *websocket.Conn)

+ func HandleWebsocketClose(message ControllerMessage)

+ func InitClient() *websocket.Conn

+ func Main()

+ func ScanFile(input chan string)

+ func SendIdentity(connection *websocket.Conn, clientId string)

+ type ClientOptions struct

+ Domain *utils.Domain

+ Env string

+ Listen bool

+ LogLevel zapcore.Level

+ Output bool

+ PeerId string

+ func InitOptions() *ClientOptions

+ type ControllerMessage struct

+ Connection *websocket.Conn

+ Error error

+ Message string

+ type IdentityMessage struct

+ Broadcaster bool

+ PeerId string

+ Subscriber bool

+ type LogMessage struct

+ Line string

+ type Message struct

+ Event string

+ Id string

+ Payload interface{}

+ func (message Message) MarshalLogObject(encoder zapcore.ObjectEncoder) error