topic

Documentation

Index

• func ExtractOtel(ctx context.Context, message *pubsub.Message) context.Context
• func InjectOtel(ctx context.Context, message *pubsub.Message)
• type GoogleTopic
  • func NewGoogleTopic(ctx context.Context, projectID, topicID string) (*GoogleTopic, error)
  • func (t *GoogleTopic) Close(ctx context.Context) error
  • func (t *GoogleTopic) Publish(ctx context.Context, message Message) error
• type Message
• type SpyTopic
  • func NewSpyTopic() *SpyTopic
  • func (t *SpyTopic) Publish(ctx context.Context, message Message) error
  • func (t *SpyTopic) ReceivedData() []Message
• type Topic

Functions

func ExtractOtel

func ExtractOtel(ctx context.Context, message *pubsub.Message) context.Context

func InjectOtel

func InjectOtel(ctx context.Context, message *pubsub.Message)

Types

type GoogleTopic

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

GoogleTopic is a wrapper for Google Cloud Pub/Sub Topic.

func NewGoogleTopic

func NewGoogleTopic(ctx context.Context, projectID, topicID string) (*GoogleTopic, error)

func (*GoogleTopic) Close

func (t *GoogleTopic) Close(ctx context.Context) error

func (*GoogleTopic) Publish

func (t *GoogleTopic) Publish(ctx context.Context, message Message) error

type Message

type Message struct {
	Data        []byte
	Attributes  map[string]string
	OrderingKey string
}

type SpyTopic

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

func NewSpyTopic

func NewSpyTopic() *SpyTopic

func (*SpyTopic) Publish

func (t *SpyTopic) Publish(ctx context.Context, message Message) error

func (*SpyTopic) ReceivedData

func (t *SpyTopic) ReceivedData() []Message

ReceivedData is a test helper to get the list of message data sent by SUT.

type Topic

type Topic interface {
	Publish(ctx context.Context, message Message) error
}