inmemory

Documentation

Index

• func NewWrappedInMemory(t *testing.T, fopts ...Option) pubsub.PubSub
• type Option
  • func WithFeatures(features ...pubsub.Feature) Option
  • func WithPublishFn(fn func(ctx context.Context, req *pubsub.PublishRequest) error) Option
• type WrappedInMemory
  • func (w *WrappedInMemory) Close() error
  • func (w *WrappedInMemory) Init(ctx context.Context, metadata pubsub.Metadata) error
  • func (w *WrappedInMemory) Publish(ctx context.Context, req *pubsub.PublishRequest) error

Functions

func NewWrappedInMemory

func NewWrappedInMemory(t *testing.T, fopts ...Option) pubsub.PubSub

Types

type Option

type Option func(*options)

Option is a function that configures the process.

func WithFeatures

func WithFeatures(features ...pubsub.Feature) Option

func WithPublishFn

func WithPublishFn(fn func(ctx context.Context, req *pubsub.PublishRequest) error) Option

type WrappedInMemory

type WrappedInMemory struct {
	pubsub.PubSub
	// contains filtered or unexported fields
}

Wrapped is a wrapper around inmemory pubsub to ensure that Init and Close are called only once.

func (*WrappedInMemory) Close

func (w *WrappedInMemory) Close() error

func (*WrappedInMemory) Init

func (w *WrappedInMemory) Init(ctx context.Context, metadata pubsub.Metadata) error

func (*WrappedInMemory) Publish

func (w *WrappedInMemory) Publish(ctx context.Context, req *pubsub.PublishRequest) error