queue

Documentation

Index

• Variables
• type Service
  • func NewLoggingMiddleware(svc Service, log *slog.Logger) Service
  • func NewService(client ServiceClient) Service
  • func NewServiceMock(msgs []*pb.CloudEvent) Service

Variables

var ErrInternal = errors.New("queue: internal failure")

var ErrQueueMissing = errors.New("missing queue")

Types

type Service

type Service interface {
	SetConsumer(ctx context.Context, name, subj string) (err error)
	ReceiveMessages(ctx context.Context, queue, subj string, batchSize uint32, consume util.ConsumeFunc[[]*pb.CloudEvent]) (err error)
}

func NewLoggingMiddleware

func NewLoggingMiddleware(svc Service, log *slog.Logger) Service

func NewService

func NewService(client ServiceClient) Service

func NewServiceMock

func NewServiceMock(msgs []*pb.CloudEvent) Service