pubsubutil

Documentation

Index

• Variables
• func GetTopic(ctx context.Context, topicID string) (*pubsub.Topic, error)
• func Start(ctx context.Context, c PubsubConfig) error
• func Subscribe(ctx context.Context, topicID string, ...) error
• type PubsubConfig
  • func ParsePubsubConfig(config map[string]string) (PubsubConfig, error)
• type Topic

Variables

var (
	UseProtobuf = false
)

Functions

func GetTopic

func GetTopic(ctx context.Context, topicID string) (*pubsub.Topic, error)

func Start

func Start(ctx context.Context, c PubsubConfig) error

func Subscribe

func Subscribe(ctx context.Context, topicID string, handler func(context.Context, *pubsub.Message)) error

Types

type PubsubConfig

type PubsubConfig struct {
	Host      string           `yaml:"host"`
	Port      string           `yaml:"port"`
	Projectid string           `yaml:"projectid"`
	Emulator  bool             `yaml:"emulator"`
	Topics    map[string]Topic `yaml:"topics"`
}

func ParsePubsubConfig

func ParsePubsubConfig(config map[string]string) (PubsubConfig, error)

type Topic

type Topic struct {
	Name                   string `yaml:"name"`
	Subscription           string `yaml:"subscription"`
	CreateTopic            bool   `yaml:"createTopic"`
	CreateSubscription     bool   `yaml:"createSubscription"`
	Concurrency            int    `yaml:"concurrency"`
	MaxOutstandingMessages int    `yaml:"maxOutstandingMessages"`
}