notificationhandler

Documentation

Index

• type IWebsocketActions
• type NotificationHandler
  • func NewNotificationHandler(pool *ants.PoolWithFunc, config config.IConfig) *NotificationHandler
  • func (notification *NotificationHandler) WebsocketConnection(ctx context.Context) error
• type WebsocketActions
  • func NewWebsocketActions(host string) *WebsocketActions
  • func (wa *WebsocketActions) Close() error
  • func (wa *WebsocketActions) DefaultDialer(requestHeader http.Header) (*http.Response, error)
  • func (wa *WebsocketActions) ReadMessage() (int, []byte, error)
  • func (wa *WebsocketActions) WritePingMessage() error

Types

type IWebsocketActions

type IWebsocketActions interface {
	ReadMessage() (int, []byte, error)
	Close() error
	WritePingMessage() error
	DefaultDialer(requestHeader http.Header) (*http.Response, error)
}

IWebsocketActions -

type NotificationHandler

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

func NewNotificationHandler

func NewNotificationHandler(pool *ants.PoolWithFunc, config config.IConfig) *NotificationHandler

func (*NotificationHandler) WebsocketConnection

func (notification *NotificationHandler) WebsocketConnection(ctx context.Context) error

type WebsocketActions

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

WebsocketActions -

func NewWebsocketActions

func NewWebsocketActions(host string) *WebsocketActions

NewWebsocketActions -

func (*WebsocketActions) Close

func (wa *WebsocketActions) Close() error

Close -

func (*WebsocketActions) DefaultDialer

func (wa *WebsocketActions) DefaultDialer(requestHeader http.Header) (*http.Response, error)

DefaultDialer -

func (*WebsocketActions) ReadMessage

func (wa *WebsocketActions) ReadMessage() (int, []byte, error)

ReadMessage -

func (*WebsocketActions) WritePingMessage

func (wa *WebsocketActions) WritePingMessage() error

WritePingMessage -