pubsublib

package module

v0.0.0-...-0f8213d Latest Latest Go to latest Published: Mar 25, 2024 License: MIT Imports: 7 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

This section is empty.

This section is empty.

This section is empty.

type Client struct {
	BaseURL    string
	HttpClient *http.Client
	Token      string
	ApiKey     string
}

func NewClient(baseURL string, token string, apiKey string, httpClient ...*http.Client) *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 struct {
	Messages []Message `json:"messages"`
}

type ListTopicsResponse struct {
	Topics []string `json:"topics"`
}

type Message struct {
	ID        string `json:"id"`
	Data      string `json:"data"`
	Timestamp string `json:"timestamp"`
}

type PullResponse struct {
	Message Message `json:"message"`
}

type Subscription struct {
	Name string `json:"name"`
	Type string `json:"type"`
}

type Topic struct {
	Name string `json:"name"`
	Type string `json:"type"`
}