Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Publisher ¶
type Publisher struct {
// contains filtered or unexported fields
}
A Publisher represents a publisher struct with a GCP Pub/Sub client.
func NewPublisher ¶
NewPublisher initializes a new publisher client.
type PublisherLite ¶
type PublisherLite struct {
// contains filtered or unexported fields
}
A PublisherLite represents a publisher struct with a GCP Pub/Sub Lite client.
func NewPublisherLite ¶
func NewPublisherLite(ctx context.Context, cfg config.Destination) (*PublisherLite, error)
NewPublisherLite initializes a new publisher client of GCP Pub/Sub Lite.
func (*PublisherLite) Stop ¶
func (pl *PublisherLite) Stop() error
Stop sends all remaining published messages and closes publish streams.
type Subscriber ¶
type Subscriber struct {
// contains filtered or unexported fields
}
Subscriber represents a struct with a GCP Pub/Sub client, queues for messages, an error channel.
func NewSubscriber ¶
NewSubscriber initializes a new subscriber client of GCP Pub/Sub and starts receiving a messages to the message queue.
func (*Subscriber) Stop ¶
func (s *Subscriber) Stop() error
Stop calls stop method and releases the GCP Pub/Sub client.
type SubscriberLite ¶
type SubscriberLite struct {
// contains filtered or unexported fields
}
SubscriberLite represents queues for messages, an error channel.
func NewSubscriberLite ¶
NewSubscriberLite initializes a new subscriber client of GCP Pub/Sub Lite and starts receiving a messages to the message queue.
Source Files