queue

Documentation

Index

• Variables
• func NewMessagesWriterMock() model.MessageWriter
• type Service
  • func NewLoggingMiddleware(svc Service, log *slog.Logger) Service
  • func NewService(client ServiceClient) Service
  • func NewServiceMock() Service

Variables

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

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

Functions

func NewMessagesWriterMock

func NewMessagesWriterMock() model.MessageWriter

Types

type Service

type Service interface {
	SetQueue(ctx context.Context, name string, limit uint32) (err error)
	NewQueueWriter(ctx context.Context, name string) (mw model.MessageWriter, err error)
	ReceiveMessages(ctx context.Context, queue string, batchSize uint32, consume util.ConsumeFunc[[]*pb.CloudEvent]) (n uint32, err error)
}

func NewLoggingMiddleware

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

func NewService

func NewService(client ServiceClient) Service

func NewServiceMock

func NewServiceMock() Service