Documentation ¶
Index ¶
- type Storage
- func (s *Storage) CreateTables()
- func (s *Storage) DropTables()
- func (s *Storage) FlushAll()
- func (s *Storage) GetFromRevision(id string, from int) ([]goes.Event, error)
- func (s *Storage) GetLastEvent(id string) ([]goes.Event, error)
- func (s *Storage) GetSnapshot(id string, version int) (*goes.Snapshot, error)
- func (s *Storage) GetUndispatchedEvent() ([]goes.Event, error)
- func (s *Storage) MarkDispatchedEvent(es []goes.Event) error
- func (s *Storage) Save(es []goes.Event) error
- func (s *Storage) SaveSnapshot(snap *goes.Snapshot) error
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Storage ¶
type Storage struct {
// contains filtered or unexported fields
}
Storage mysql
func (*Storage) GetFromRevision ¶
GetFromRevision get events from revision
func (*Storage) GetLastEvent ¶
GetLastEvent get all event
func (*Storage) GetSnapshot ¶
GetSnapshot get snapshot with version
func (*Storage) GetUndispatchedEvent ¶
GetUndispatchedEvent get undispatched event
func (*Storage) MarkDispatchedEvent ¶
MarkDispatchedEvent makr event dispatched
Click to show internal directories.
Click to hide internal directories.