event

type Event interface {
	Version() uint64
	EventType() string
}

type EventUnmarshaler struct {
	Version     uint64
	EventType   string
	AggregateId string
	GroupId     string
	Unmarshal   func(v interface{}) error
}

type Handler interface {
	Handle(ctx context.Context, iter Iter) (err error)
}

type Iter interface {
	Next(ctx context.Context, eventUnmarshaler *EventUnmarshaler) bool
	Err() error
}

type MarshalerFunc func(v interface{}) ([]byte, error)

type UnmarshalerFunc func(b []byte, v interface{}) error