domain

Documentation

Index

• Constants
• Variables
• type EventHandler
• type EventHandlerFunc
• type EventUnmarshallingError
  • func (e EventUnmarshallingError[T]) Error() string
• type FailedToCreateStreamError
  • func (f FailedToCreateStreamError) Error() string
• type PublishableMessage

Constants

const PublishedEventsMetricPointName = "published_events"

const ReceivedEventsMetricPointName = "received_events"

Variables

var (
	LogEventsScope = namespace.Namespace{Identifier: ReceivedEventsMetricPointName}

	LogEventsSubscriptionsScope = namespace.Namespace{Identifier: "subscriptions"}
	LogEventsReceivedScope      = namespace.Namespace{Identifier: "received"}
)

var (
	LogEventsSubscriptionChannelField = namespace.Namespace{Parent: &LogEventsSubscriptionsScope, Identifier: "channel"}
	LogEventsSubscriptionCountField   = namespace.Namespace{Parent: &LogEventsSubscriptionsScope, Identifier: "count"}
	LogEventsSubscriptionKindField    = namespace.Namespace{Parent: &LogEventsSubscriptionsScope, Identifier: "kind"}

	LogEventsReceivedChannelField       = namespace.Namespace{Parent: &LogEventsReceivedScope, Identifier: "channel"}
	LogEventsReceivedEventTypeField     = namespace.Namespace{Parent: &LogEventsReceivedScope, Identifier: "event_type"}
	LogEventsReceivedMessageIdField     = namespace.Namespace{Parent: &LogEventsReceivedScope, Identifier: "message_id"}
	LogEventsReceivedCorrelationIdField = namespace.Namespace{Parent: &LogEventsReceivedScope, Identifier: "correlation_id"}
	LogEventsReceivedPayloadField       = namespace.Namespace{Parent: &LogEventsReceivedScope, Identifier: "payload"}
	LogEventsReceivedStatusField        = namespace.Namespace{Parent: &LogEventsReceivedScope, Identifier: "status"}
)

var ErrEventHeaderShouldBeAString = errors.New("the event header should be a string but got an unsupported type")

var ErrFailedToValidateEventHeader = errors.New("failed to validate event header")

var ErrUnableToReadFromGroup = errors.New("unable to read from group")

var ErrUnableToUnmarshalEventHeader = errors.New("unable to unmarshal the header in a json document")

Types

type EventHandler

type EventHandler interface {
	Register(event string, handler EventHandlerFunc)

	MsgReceived(ctx context.Context, event contract.Message, ack func())
}

type EventHandlerFunc

type EventHandlerFunc func(ctx context.Context, eventJson string) error

type EventUnmarshallingError

type EventUnmarshallingError[T any] struct {
	Event T
}

func (EventUnmarshallingError[T]) Error

func (e EventUnmarshallingError[T]) Error() string

type FailedToCreateStreamError

type FailedToCreateStreamError struct {
	Stream string
}

func (FailedToCreateStreamError) Error

func (f FailedToCreateStreamError) Error() string

type PublishableMessage

type PublishableMessage interface {
	Channel() string
	EventType() string
}