inbox

Documentation

Index

• type IDKey
• type Inboxer
  • func New(ctx context.Context, receiver pubsub.Receiver) Inboxer
• type MessageHandler

Types

type IDKey

type IDKey struct{}

type Inboxer

type Inboxer interface {
	ID() string
	Start() error
	Close() error
	Consume(ctx context.Context, handler MessageHandler) error
}

func New

func New(ctx context.Context, receiver pubsub.Receiver) Inboxer

type MessageHandler

type MessageHandler func(ctx context.Context, msgCtx message.Context) error