bus

Documentation

Index

• type Client
  • func (c *Client) Connect() error
  • func (c *Client) Push(payload []byte, topic string) error
  • func (c *Client) PushRoutine(payload []byte, topic string, ch chan error)

Types

type Client

type Client struct {
	// GCP Project ID
	ProjectID string
	Ctx       context.Context
	Opts      []option.ClientOption
	Instance  *pubsub.Client
}

Client defines the client to communicate with the message bus.

func (*Client) Connect

func (c *Client) Connect() error

Connect establishes connector to the message broker.

func (*Client) Push

func (c *Client) Push(payload []byte, topic string) error

Push pushes the message to a topic.

func (*Client) PushRoutine

func (c *Client) PushRoutine(payload []byte, topic string, ch chan error)

PushRoutine marshal the output payload object.