matches

Documentation

Index

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

Variables

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

ErrInternal indicates some unexpected internal failure.

Types

type Service

type Service interface {

	// Search finds all matching subscription ids and supplies them to the specified consume function.
	Search(ctx context.Context, msgId string, consume util.ConsumeFunc[string]) (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