Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type CassandraEventStore ¶
type CassandraEventStore struct {
// contains filtered or unexported fields
}
func NewCassandraEventStore ¶
func NewCassandraEventStore(session *gocql.Session) (*CassandraEventStore, error)
func (CassandraEventStore) GetEvents ¶
func (ces CassandraEventStore) GetEvents(aggregateType es.AggregateType, aggregateID es.AggregateID) ([]es.Event, error)
func (CassandraEventStore) StoreEvents ¶
type EventHandler ¶
type EventHandler interface {
HandleEvent(ctx context.Context, event eventsourcing.EventData) error
Events() []eventsourcing.EventType
Name() string
}
type KafkaEventMessaging ¶
type KafkaEventMessaging struct {
// contains filtered or unexported fields
}
func NewKafkaEventMessaging ¶
func (*KafkaEventMessaging) Close ¶
func (c *KafkaEventMessaging) Close()
func (*KafkaEventMessaging) ConsumeEvents ¶
func (c *KafkaEventMessaging) ConsumeEvents(ctx context.Context, handler EventHandler) error
func (*KafkaEventMessaging) PublishEvents ¶
func (p *KafkaEventMessaging) PublishEvents(ctx context.Context, events []eventsourcing.Event) error
Source Files
Click to show internal directories.
Click to hide internal directories.