Documentation
¶
Index ¶
- Variables
- type Collector
- type ErrDeserializingEvent
- type ErrDeserializingPayload
- type ErrPublishingEvent
- type ErrSerializingEvent
- type ErrSerializingPayload
- type ErrSubscribingToSubject
- type Event
- type Handler
- type LocalEventBus
- type NatsEvent
- type NatsEventBus
- type Publishable
- type Publisher
- type Subscriber
Constants ¶
This section is empty.
Variables ¶
View Source
var ( ErrInvalidEvent = errors.New("invalid event") ErrUnknownPayload = errors.New("unknown event payload") )
Functions ¶
This section is empty.
Types ¶
type Collector ¶ added in v0.2.0
type Collector struct {
// contains filtered or unexported fields
}
func NewCollector ¶ added in v0.2.0
func NewCollector() *Collector
func (*Collector) Record ¶ added in v0.2.0
func (c *Collector) Record(publishable Publishable) error
type ErrDeserializingEvent ¶ added in v0.2.0
type ErrDeserializingEvent struct {
// contains filtered or unexported fields
}
ErrDeserializingEvent
func (*ErrDeserializingEvent) Error ¶ added in v0.2.0
func (e *ErrDeserializingEvent) Error() string
func (*ErrDeserializingEvent) Unwrap ¶ added in v0.2.0
func (e *ErrDeserializingEvent) Unwrap() error
type ErrDeserializingPayload ¶ added in v0.2.0
type ErrDeserializingPayload struct { Event *Event // contains filtered or unexported fields }
ErrDeserializingPâyload
func (*ErrDeserializingPayload) Error ¶ added in v0.2.0
func (e *ErrDeserializingPayload) Error() string
func (*ErrDeserializingPayload) Unwrap ¶ added in v0.2.0
func (e *ErrDeserializingPayload) Unwrap() error
type ErrPublishingEvent ¶ added in v0.2.0
type ErrPublishingEvent struct { Event *Event // contains filtered or unexported fields }
ErrPublishingEvent
func (*ErrPublishingEvent) Error ¶ added in v0.2.0
func (e *ErrPublishingEvent) Error() string
func (*ErrPublishingEvent) Unwrap ¶ added in v0.2.0
func (e *ErrPublishingEvent) Unwrap() error
type ErrSerializingEvent ¶ added in v0.2.0
type ErrSerializingEvent struct { Event *Event // contains filtered or unexported fields }
ErrSerializingEvent
func (*ErrSerializingEvent) Error ¶ added in v0.2.0
func (e *ErrSerializingEvent) Error() string
func (*ErrSerializingEvent) Unwrap ¶ added in v0.2.0
func (e *ErrSerializingEvent) Unwrap() error
type ErrSerializingPayload ¶ added in v0.2.0
type ErrSerializingPayload struct { Event *Event // contains filtered or unexported fields }
ErrSerializingPayload
func (*ErrSerializingPayload) Error ¶ added in v0.2.0
func (e *ErrSerializingPayload) Error() string
func (*ErrSerializingPayload) Unwrap ¶ added in v0.2.0
func (e *ErrSerializingPayload) Unwrap() error
type ErrSubscribingToSubject ¶ added in v0.2.0
type ErrSubscribingToSubject struct { Subject string // contains filtered or unexported fields }
ErrSubscribingToEvent
func (*ErrSubscribingToSubject) Error ¶ added in v0.2.0
func (e *ErrSubscribingToSubject) Error() string
func (*ErrSubscribingToSubject) Unwrap ¶ added in v0.2.0
func (e *ErrSubscribingToSubject) Unwrap() error
type Event ¶
type Event struct {
// contains filtered or unexported fields
}
func CreateEvent ¶
func (*Event) UnmarshalPayload ¶
type LocalEventBus ¶
type LocalEventBus struct {
// contains filtered or unexported fields
}
func NewLocalEventBus ¶
func NewLocalEventBus() *LocalEventBus
type NatsEventBus ¶
type NatsEventBus struct {
// contains filtered or unexported fields
}
func NewNatsEventBus ¶
func NewNatsEventBus( consumerGroup string, conn *nats.Conn, ) *NatsEventBus
type Publishable ¶
Click to show internal directories.
Click to hide internal directories.