Versions in this module Expand all Collapse all v4 v4.0.0 Jan 10, 2023 Changes in this version + type Callback func(ctx context.Context, message transport.Message) + type Message struct + Operation string + Payload string + Topic string + Type string + func NewAuthorizationMessage(token string) Message + func NewMessageFromByteSlice(slice []byte) (*Message, error) + func NewPublicationMessage(topic string, messageType, message string) Message + func NewSubscriptionMessage(topic string) Message + func (m *Message) GetPayload(out interface{}) error + func (m Message) ToByteSlice() []byte + func (m Message) ToSlice() []string + func (m Message) ToString() string + type PubSubTransporterMock struct + func NewPubSubTransporterMock() *PubSubTransporterMock + func (m *PubSubTransporterMock) Connect() error + func (m *PubSubTransporterMock) Connection() *websocket.Conn + func (m *PubSubTransporterMock) Disconnect() error + func (m *PubSubTransporterMock) IsConnected() bool + func (m *PubSubTransporterMock) Publish(message Message) error + func (m *PubSubTransporterMock) Subscribe(topic string, cb Callback) error + func (m *PubSubTransporterMock) Unsubscribe(topic string) error + type PubSubWebsocketTransporter interface + func NewIgnWebsocketTransporter(baseCtx context.Context, host, path, scheme, token string) (PubSubWebsocketTransporter, error) + type Publisher interface + Publish func(message Message) error + type Subscriber interface + Subscribe func(topic string, cb Callback) error + Unsubscribe func(topic string) error
Go to main page