internal

Documentation

Index

• func TopicID(name TopicName) string
• type Client
  • func NewClient(ctx context.Context, projectID, svcID, envID, adcCredPath string) (Client, error)
  • func NewWithPubSubClient(cli *pubsub.Client, projectID, svcID, envID string) Client
• type Config
  • func NewConfig() Config
• type Handler
• type SubscriptionOpt
• type Topic
• type TopicName

Functions

func TopicID

func TopicID(name TopicName) string

TopicID ...

Types

type Client

type Client interface {
	Topic(topicID string) Topic
	Pub(ctx context.Context, topicID string, evt event.Event) error
	Sub(ctx context.Context, topicID string, handler Handler, opts ...SubscriptionOpt) error
	Close()
}

Client ...

func NewClient

func NewClient(ctx context.Context, projectID, svcID, envID, adcCredPath string) (Client, error)

NewClient ...

func NewWithPubSubClient

func NewWithPubSubClient(cli *pubsub.Client, projectID, svcID, envID string) Client

NewWithPubSubClient ...

type Config

type Config interface {
	Project() string
	Service() string
	EnvID() string
	CredPath() string
}

Config ...

func NewConfig

func NewConfig() Config

NewConfig ...

type Handler

type Handler func(ctx context.Context, evt event.Event) error

Handler ...

type SubscriptionOpt

type SubscriptionOpt func(*pubsub.ReceiveSettings)

SubscriptionOpt ...

type Topic

type Topic interface {
	Pub(ctx context.Context, evt event.Event) error
	Sub(ctx context.Context, handler Handler, opts ...SubscriptionOpt) error
}

Topic ...

type TopicName

type TopicName string

TopicName ...