Documentation ¶
Index ¶
- type Client
- type DefaultClient
- func (s *DefaultClient) Connect(ctx context.Context) (responses.ConnectResponse, error)
- func (s *DefaultClient) Disconnect(ctx context.Context) (responses.DisconnectResponse, error)
- func (s *DefaultClient) Handshake(ctx context.Context) (responses.SuccessfulHandshakeResponse, error)
- func (s *DefaultClient) SubscribeToPushTopic(ctx context.Context, pushTopic string) (responses.SubscribeResponse, error)
- func (s *DefaultClient) UnsubscribeToPushTopic(ctx context.Context, pushTopic string) (responses.UnsubscribeResponse, error)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Client ¶
type Client interface { Handshake(ctx context.Context) (responses.SuccessfulHandshakeResponse, error) Connect(ctx context.Context) (responses.ConnectResponse, error) SubscribeToPushTopic(ctx context.Context, pushTopic string) (responses.SubscribeResponse, error) UnsubscribeToPushTopic(ctx context.Context, pushTopic string) (responses.UnsubscribeResponse, error) Disconnect(ctx context.Context) (responses.DisconnectResponse, error) }
func NewDefaultClient ¶
type DefaultClient ¶
type DefaultClient struct {
// contains filtered or unexported fields
}
func (*DefaultClient) Connect ¶
func (s *DefaultClient) Connect(ctx context.Context) (responses.ConnectResponse, error)
Connect performs a connect request. See: https://docs.cometd.org/current7/reference/#_bayeux_meta_connect
func (*DefaultClient) Disconnect ¶
func (s *DefaultClient) Disconnect(ctx context.Context) (responses.DisconnectResponse, error)
Disconnect performs a disconnect request. See: https://docs.cometd.org/current7/reference/#_bayeux_meta_disconnect
func (*DefaultClient) Handshake ¶
func (s *DefaultClient) Handshake(ctx context.Context) (responses.SuccessfulHandshakeResponse, error)
Handshake performs a handshake request. See: https://docs.cometd.org/current7/reference/#_bayeux_meta_handshake
func (*DefaultClient) SubscribeToPushTopic ¶
func (s *DefaultClient) SubscribeToPushTopic(ctx context.Context, pushTopic string) (responses.SubscribeResponse, error)
SubscribeToPushTopic performs a subscribe to topic request. See: https://docs.cometd.org/current7/reference/#_bayeux_meta_subscribe
func (*DefaultClient) UnsubscribeToPushTopic ¶
func (s *DefaultClient) UnsubscribeToPushTopic(ctx context.Context, pushTopic string) (responses.UnsubscribeResponse, error)
UnsubscribeToPushTopic performs a unsubscribe from topic request. See: https://docs.cometd.org/current7/reference/#_bayeux_meta_unsubscribe
Click to show internal directories.
Click to hide internal directories.