googlepubsub_adapter

Documentation

Index

• type GooglePubsubAdapter
  • func New(ctx context.Context, projectID string, opts ...option.ClientOption) *GooglePubsubAdapter
  • func NewConn(c *pubsub.Client) *GooglePubsubAdapter
  • func (gpb *GooglePubsubAdapter) Close() error
  • func (gpb *GooglePubsubAdapter) Listener(ctx context.Context, fn func(discourse.Message) error, ...) error
  • func (gpb *GooglePubsubAdapter) Publish(ctx context.Context, message discourse.Publisher) error

Types

type GooglePubsubAdapter

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

func New

func New(ctx context.Context, projectID string, opts ...option.ClientOption) *GooglePubsubAdapter

func NewConn

func NewConn(c *pubsub.Client) *GooglePubsubAdapter

func (*GooglePubsubAdapter) Close

func (gpb *GooglePubsubAdapter) Close() error

func (*GooglePubsubAdapter) Listener

func (gpb *GooglePubsubAdapter) Listener(ctx context.Context, fn func(discourse.Message) error, cfgSubcription discourse.Subscription) error

func (*GooglePubsubAdapter) Publish

func (gpb *GooglePubsubAdapter) Publish(ctx context.Context, message discourse.Publisher) error