writer

Documentation

Index

• Variables
• type Service
  • func NewLogging(svc Service, log *slog.Logger) Service
  • func NewMock() Service
  • func NewService(clientAwk api.Client, backoffTimeLimit time.Duration, ...) Service

Variables

var ErrWrite = errors.New("failed to write event")

Types

type Service

type Service interface {
	io.Closer
	Write(ctx context.Context, evt *pb.CloudEvent, groupId, userId string) (err error)
}

func NewLogging

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

func NewMock

func NewMock() Service

func NewService

func NewService(clientAwk api.Client, backoffTimeLimit time.Duration, cfgCache config.WriterCacheConfig, log *slog.Logger) Service