events

Documentation

Index

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

Variables

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

ErrInternal indicates some unexpected internal failure.

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

Types

type Service

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

func NewLoggingMiddleware

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

func NewService

func NewService(client ServiceClient) Service

func NewServiceMock

func NewServiceMock() Service

type Writer

type Writer interface {
	io.Closer

	// Write writes the specified messages and returns the accepted count preserving the order.
	// Returns io.EOF if the destination file/connection/whatever is closed.
	Write(ctx context.Context, msgs []*pb.CloudEvent) (ackCount uint32, err error)
}

func NewPublisherMock

func NewPublisherMock() Writer