stream

Documentation

Index

• type PublishRequest
• type PublishResponse
• type StreamService
  • func NewStreamService(token string) *StreamService
  • func (t *StreamService) Publish(request *PublishRequest) (*PublishResponse, error)
  • func (t *StreamService) Subscribe(request *SubscribeRequest) (*SubscribeResponse, error)
• type SubscribeRequest
• type SubscribeResponse

Types

type PublishRequest

type PublishRequest struct {
	// The json message to publish
	Message map[string]interface{} `json:"message"`
	// The topic to publish to
	Topic string `json:"topic"`
}

type PublishResponse

type PublishResponse struct {
}

type StreamService

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

func NewStreamService

func NewStreamService(token string) *StreamService

func (*StreamService) Publish

func (t *StreamService) Publish(request *PublishRequest) (*PublishResponse, error)

Publish a message to the stream. Specify a topic to group messages for a specific topic.

func (*StreamService) Subscribe

func (t *StreamService) Subscribe(request *SubscribeRequest) (*SubscribeResponse, error)

Subscribe to messages for a given topic.

type SubscribeRequest

type SubscribeRequest struct {
	// The topic to subscribe to
	Topic string `json:"topic"`
}

type SubscribeResponse

type SubscribeResponse struct {
	// The next json message on the topic
	Message map[string]interface{} `json:"message"`
	// The topic subscribed to
	Topic string `json:"topic"`
}