Documentation
¶
Index ¶
- Constants
- func NewRetrieveEventsUseCase(stream esApi.EventStore_RetrieveServer, store es.EventStore, ...) usecase.UseCase
- func NewRetrieveOrEventsUseCase(stream esApi.EventStore_RetrieveServer, store es.EventStore, ...) usecase.UseCase
- func NewStoreEventsUseCase(stream esApi.EventStore_StoreServer, store es.EventStore, ...) usecase.UseCase
- func NewStoreQueryFromProto(protoFilter *esApi.EventFilter) (*es.StoreQuery, error)
- type RetrieveEventsUseCase
- type StoreEventsUseCase
Constants ¶
View Source
const (
MAX_BACKOFF_PUBLISH = 1 * time.Minute
)
Variables ¶
This section is empty.
Functions ¶
func NewRetrieveEventsUseCase ¶
func NewRetrieveEventsUseCase(stream esApi.EventStore_RetrieveServer, store es.EventStore, eventFilter *esApi.EventFilter, metrics *metrics.EventStoreMetrics) usecase.UseCase
func NewRetrieveOrEventsUseCase ¶ added in v0.3.6
func NewRetrieveOrEventsUseCase(stream esApi.EventStore_RetrieveServer, store es.EventStore, eventFilters *esApi.EventFilters, metrics *metrics.EventStoreMetrics) usecase.UseCase
func NewStoreEventsUseCase ¶
func NewStoreEventsUseCase(stream esApi.EventStore_StoreServer, store es.EventStore, bus es.EventBusPublisher, metrics *metrics.EventStoreMetrics) usecase.UseCase
NewStoreEventsUseCase creates a new usecase which stores all events in the store and broadcasts these events via the message bus
func NewStoreQueryFromProto ¶
func NewStoreQueryFromProto(protoFilter *esApi.EventFilter) (*es.StoreQuery, error)
NewStoreQueryFromProto converts proto esApi.EventFilter to storage.StoreQuery
Types ¶
type RetrieveEventsUseCase ¶
type RetrieveEventsUseCase struct {
*usecase.UseCaseBase
// contains filtered or unexported fields
}
type StoreEventsUseCase ¶
type StoreEventsUseCase struct {
*usecase.UseCaseBase
// contains filtered or unexported fields
}
Source Files
Click to show internal directories.
Click to hide internal directories.