pub

Documentation

Index

• Variables
• type Service
  • func NewLogging(svc Service, log *slog.Logger) Service
  • func NewMock() Service
  • func NewService(clientHttp *http.Client, url, token string) Service

Variables

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

var ErrLimitReached = errors.New("publishing limit reached")

var ErrNoAck = errors.New("publishing is not acknowledged")

var ErrNoAuth = errors.New("unauthenticated request")

Types

type Service

type Service interface {
	Publish(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(clientHttp *http.Client, url, token string) Service