events

Documentation

Index

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

Variables

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

ErrInternal indicates some unexpected internal failure.

var ErrInvalid = errors.New("events: invalid request")

Functions

func NewPublisherMock

func NewPublisherMock() model.MessagesWriter

Types

type Service

type Service interface {
	SetStream(ctx context.Context, topic string, limit uint32) (err error)
	NewPublisher(ctx context.Context, topic string) (p model.MessagesWriter, err error)
}

func NewLoggingMiddleware

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

func NewService

func NewService(client ServiceClient) Service

func NewServiceMock

func NewServiceMock() Service