Documentation ¶
Index ¶
- type Client
- func (cli *Client) CreateSubscription(topicName string, subscription Subscription) error
- func (cli *Client) CreateTopic(topic Topic) error
- func (cli *Client) EnsureTopicExists(topic string) error
- func (cli *Client) GetMessages(topic string) ([]Message, error)
- func (cli *Client) ListTopics() ([]string, error)
- func (cli *Client) PublishMessage(topicName string, message Message) error
- func (cli *Client) PullMessage(subscriptionName string) (*Message, error)
- func (cli *Client) TopicExists(topic string) (bool, error)
- type GetMessagesResponse
- type ListTopicsResponse
- type Message
- type PullResponse
- type Subscription
- type Topic
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Client ¶
func (*Client) CreateSubscription ¶
func (cli *Client) CreateSubscription(topicName string, subscription Subscription) error
func (*Client) CreateTopic ¶
func (*Client) EnsureTopicExists ¶
func (*Client) ListTopics ¶
func (*Client) PublishMessage ¶
func (*Client) PullMessage ¶
type GetMessagesResponse ¶
type GetMessagesResponse struct {
Messages []Message `json:"messages"`
}
type ListTopicsResponse ¶
type ListTopicsResponse struct {
Topics []string `json:"topics"`
}
type PullResponse ¶
type PullResponse struct {
Message Message `json:"message"`
}
type Subscription ¶
Click to show internal directories.
Click to hide internal directories.