Documentation
¶
Index ¶
- type Store
- func (s *Store) Append(event model.NormalizedEvent, receivedAt time.Time) (model.Envelope, error)
- func (s *Store) AppendMessage(runner, sessionID string, msg model.Message) error
- func (s *Store) ClearMessages(runner, sessionID string) error
- func (s *Store) Fetch(consumerID string, limit int, peek bool) (model.FetchResponse, error)
- func (s *Store) GetAndClearMessages(runner, sessionID string) ([]model.Message, error)
- func (s *Store) GetMessages(runner, sessionID string) ([]model.Message, error)
- func (s *Store) GetSession(runner, sessionID string) (*model.SessionData, error)
- func (s *Store) LoadCursor(consumerID string) (model.Cursor, error)
- func (s *Store) Partitions() ([]string, error)
- func (s *Store) ReadBatch(cursor model.Cursor, limit int) ([]model.Envelope, model.Cursor, bool, error)
- func (s *Store) RebuildIndexes() error
- func (s *Store) RebuildSessions() error
- func (s *Store) SaveCursor(consumerID string, cursor model.Cursor) error
- func (s *Store) WriteSession(runner, sessionID string, data model.SessionData) error
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Store ¶
type Store struct {
Home string
}
func (*Store) AppendMessage ¶ added in v0.0.18
func (*Store) ClearMessages ¶ added in v0.0.18
func (*Store) GetAndClearMessages ¶ added in v0.0.18
func (*Store) GetMessages ¶ added in v0.0.18
func (*Store) GetSession ¶ added in v0.0.18
func (s *Store) GetSession(runner, sessionID string) (*model.SessionData, error)
func (*Store) Partitions ¶
func (*Store) RebuildIndexes ¶
func (*Store) RebuildSessions ¶
func (*Store) WriteSession ¶ added in v0.0.18
func (s *Store) WriteSession(runner, sessionID string, data model.SessionData) error
Source Files
Click to show internal directories.
Click to hide internal directories.