Documentation ¶
Index ¶
- Variables
- type InMemoryStore
- func (s *InMemoryStore) Append(event *store.Event) error
- func (s *InMemoryStore) Cleanup() error
- func (s *InMemoryStore) Get(originator *common.Originator, fromVersion bool) ([]*store.Event, error)
- func (s *InMemoryStore) Logs(fromID uint64, size uint32, pipelineID string) ([]*store.AppLogEntry, error)
- type SqlStore
- func (estore *SqlStore) Append(event *store.Event) error
- func (estore *SqlStore) Cleanup() error
- func (estore *SqlStore) Get(originator *common.Originator, fromVersion bool) ([]*store.Event, error)
- func (estore *SqlStore) Logs(fromID uint64, size uint32, pipelineID string) ([]*store.AppLogEntry, error)
- type Store
- type StoreWithCleanup
- type StoredEvent
- type StoredLogEntry
Constants ¶
This section is empty.
Variables ¶
View Source
var ErrDuplicate = errors.New("duplicate")
Functions ¶
This section is empty.
Types ¶
type InMemoryStore ¶
type InMemoryStore struct {
// contains filtered or unexported fields
}
func (*InMemoryStore) Get ¶
func (s *InMemoryStore) Get(originator *common.Originator, fromVersion bool) ([]*store.Event, error)
func (*InMemoryStore) Logs ¶
func (s *InMemoryStore) Logs(fromID uint64, size uint32, pipelineID string) ([]*store.AppLogEntry, error)
type SqlStore ¶
type SqlStore struct {
// contains filtered or unexported fields
}
type StoreWithCleanup ¶
StoreWithCleanup has the same methods as Store but also has Cleanup method it's useful when working in tests with the store
func NewInMemoryStore ¶
func NewInMemoryStore() StoreWithCleanup
type StoredEvent ¶
type StoredLogEntry ¶
type StoredLogEntry struct { ID uint64 `gorm:"primary_key; AUTO_INCREMENT; not null"` ApplicationID string `gorm:"type:varchar(255); not null; index:index_app_partition; default:'consumer'"` PartitionID string `gorm:"type:varchar(255); not null; index:index_app_partition"` EventPayload string `gorm:"type:text"` CreatedAt time.Timer }
Click to show internal directories.
Click to hide internal directories.