event

Documentation

Index

• func Close()
• func OnMeowCreated(f func(MeowCreatedMessage)) error
• func PublishMeowCreated(meow schema.Meow) error
• func SetEventStore(es EventStore)
• func SubscribeMeowCreated() (<-chan MeowCreatedMessage, error)
• type EventStore
• type MeowCreatedMessage
  • func (m *MeowCreatedMessage) Key() string
• type Message
• type NatsEventStore
  • func NewNats(url string) (*NatsEventStore, error)
  • func (e *NatsEventStore) Close()
  • func (e *NatsEventStore) OnMeowCreated(f func(MeowCreatedMessage)) (err error)
  • func (e *NatsEventStore) PublishMeowCreated(meow schema.Meow) error
  • func (e *NatsEventStore) SubscribeMeowCreated() (<-chan MeowCreatedMessage, error)

Functions

func Close

func Close()

func OnMeowCreated

func OnMeowCreated(f func(MeowCreatedMessage)) error

func PublishMeowCreated

func PublishMeowCreated(meow schema.Meow) error

func SetEventStore

func SetEventStore(es EventStore)

func SubscribeMeowCreated

func SubscribeMeowCreated() (<-chan MeowCreatedMessage, error)

Types

type EventStore

type EventStore interface {
	Close()
	PublishMeowCreated(meow schema.Meow) error
	SubscribeMeowCreated() (<-chan MeowCreatedMessage, error)
	OnMeowCreated(f func(MeowCreatedMessage)) error
}

type MeowCreatedMessage

type MeowCreatedMessage struct {
	ID        string
	Body      string
	CreatedAt time.Time
}

func (*MeowCreatedMessage) Key

func (m *MeowCreatedMessage) Key() string

type Message

type Message interface {
	Key() string
}

type NatsEventStore

type NatsEventStore struct {
	// contains filtered or unexported fields
}

func NewNats

func NewNats(url string) (*NatsEventStore, error)

func (*NatsEventStore) Close

func (e *NatsEventStore) Close()

func (*NatsEventStore) OnMeowCreated

func (e *NatsEventStore) OnMeowCreated(f func(MeowCreatedMessage)) (err error)

func (*NatsEventStore) PublishMeowCreated

func (e *NatsEventStore) PublishMeowCreated(meow schema.Meow) error

func (*NatsEventStore) SubscribeMeowCreated

func (e *NatsEventStore) SubscribeMeowCreated() (<-chan MeowCreatedMessage, error)