linkws

Documentation

Index

• func InitLogInfo(syncResult *websocket.SyncResults) *log.Logger
• func NewClient(config config.NorthWsConfig) (link.Link, error)
• type WebsocketClient
  • func (w *WebsocketClient) GetFailMsg() chan []byte
  • func (w *WebsocketClient) GetLinkID() string
  • func (w *WebsocketClient) ResultCheck(syncResults chan *websocket.SyncResults)
  • func (w *WebsocketClient) Send(ctx *comctx.Context, data *link.SendMessage) error
  • func (w *WebsocketClient) SetFailMsg(fallMsg chan []byte)
  • func (w *WebsocketClient) SyncSend(ctx *comctx.Context, data []byte) error

Functions

func InitLogInfo

func InitLogInfo(syncResult *websocket.SyncResults) *log.Logger

func NewClient

func NewClient(config config.NorthWsConfig) (link.Link, error)

Types

type WebsocketClient

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

func (*WebsocketClient) GetFailMsg

func (w *WebsocketClient) GetFailMsg() chan []byte

func (*WebsocketClient) GetLinkID

func (w *WebsocketClient) GetLinkID() string

func (*WebsocketClient) ResultCheck

func (w *WebsocketClient) ResultCheck(syncResults chan *websocket.SyncResults)

func (*WebsocketClient) Send

func (w *WebsocketClient) Send(ctx *comctx.Context, data *link.SendMessage) error

func (*WebsocketClient) SetFailMsg

func (w *WebsocketClient) SetFailMsg(fallMsg chan []byte)

func (*WebsocketClient) SyncSend

func (w *WebsocketClient) SyncSend(ctx *comctx.Context, data []byte) error