pubsub_client

Documentation

Index

• type IPubsubClient
• type IPubsubPublishResult
• type IPubsubTopic
• type PubsubClient
  • func NewPubsubClient(ctx context.Context, projectID string) (*PubsubClient, error)
  • func (p *PubsubClient) Topic(topicId string) IPubsubTopic
• type PubsubPublishResult
  • func (p *PubsubPublishResult) Get(ctx context.Context) (msgID string, err error)
• type PubsubTopic
  • func (p *PubsubTopic) Publish(ctx context.Context, msg *pubsub.Message) IPubsubPublishResult

Types

type IPubsubClient

type IPubsubClient interface {
	Topic(topicId string) IPubsubTopic
}

PubsubClient

type IPubsubPublishResult

type IPubsubPublishResult interface {
	Get(ctx context.Context) (msgID string, err error)
}

PublishResult

type IPubsubTopic

type IPubsubTopic interface {
	Publish(ctx context.Context, msg *pubsub.Message) IPubsubPublishResult
}

PubsubTopic

type PubsubClient

type PubsubClient struct {
	// contains filtered or unexported fields
}

func NewPubsubClient

func NewPubsubClient(ctx context.Context, projectID string) (*PubsubClient, error)

func (*PubsubClient) Topic

func (p *PubsubClient) Topic(topicId string) IPubsubTopic

type PubsubPublishResult

type PubsubPublishResult struct {
	*pubsub.PublishResult
}

func (*PubsubPublishResult) Get

func (p *PubsubPublishResult) Get(ctx context.Context) (msgID string, err error)

type PubsubTopic

type PubsubTopic struct {
	*pubsub.Topic
}

func (*PubsubTopic) Publish

func (p *PubsubTopic) Publish(ctx context.Context, msg *pubsub.Message) IPubsubPublishResult