pubsub

package

v0.0.87 Latest Latest Go to latest Published: Mar 11, 2024 License: MIT Imports: 5 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

Repository

github.com/electivetechnology/utility-library-go

Links

Open Source Insights

Documentation ¶

Index ¶

Constants
type Client
- func NewAsyncClient() (*Client, error)
- func NewClient(ctx context.Context) (c *Client, err error)
type Message
- func NewPubSubMessage(msg *pubsub.Message) Message
type PubSubMessage

Constants ¶

View Source

const (
	MAX_MESSAGES = 10 // Maximum number of messages to book at a time
	SYNCHRONOUS  = false
)

Variables ¶

This section is empty.

Functions ¶

This section is empty.

Types ¶

type Client ¶

type Client struct {
	PubSubClient *pubsub.Client
	Ctx          context.Context
	Synchronous  bool
	MaxMessages  int
	// contains filtered or unexported fields
}

func NewAsyncClient ¶

func NewAsyncClient() (*Client, error)

func NewClient ¶

func NewClient(ctx context.Context) (c *Client, err error)

func (*Client) Publish ¶

func (psClient *Client) Publish(topic string, message Message) error

func (*Client) Pull ¶

func (psClient *Client) Pull(subscription string, handler func(message Message) bool) error

func (*Client) SetContext ¶

func (psClient *Client) SetContext(ctx context.Context)

type Message ¶

type Message interface {
	GetId() string
	GetData() ([]byte, error)
	GetAttributes() (map[string]string, error)
}

func NewPubSubMessage ¶

func NewPubSubMessage(msg *pubsub.Message) Message

type PubSubMessage ¶

type PubSubMessage struct {
	Message *pubsub.Message
}

func (PubSubMessage) GetAttributes ¶

func (message PubSubMessage) GetAttributes() (map[string]string, error)

func (PubSubMessage) GetData ¶

func (message PubSubMessage) GetData() ([]byte, error)

func (PubSubMessage) GetId ¶

func (message PubSubMessage) GetId() string

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL