pub

package

v0.0.0-...-906d962 Latest Latest Go to latest Published: Jan 1, 2025 License: AGPL-3.0 Imports: 13 Imported by: 0

Details

This section is empty.

View Source

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

View Source

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

View Source

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

View Source

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

func MarshalEvent(src *pb.CloudEvent) (data []byte, err error)

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

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

func NewMock(chEvt chan<- *pb.CloudEvent) Service

func NewService(clientHttp *http.Client, url, token string, timeout time.Duration) Service