Documentation ¶
Index ¶
- func Register(configs Configs, bulkLimit, errorCount uint64, view *view.View, ...) []query.Handler
- type Config
- type Configs
- type Styling
- func (_ *Styling) AggregateTypes() []es_models.AggregateType
- func (m *Styling) CurrentSequence() (uint64, error)
- func (m *Styling) EventQuery() (*es_models.SearchQuery, error)
- func (h *Styling) Eventstore() v1.Eventstore
- func (h *Styling) LockDuration() time.Duration
- func (h *Styling) MinimumCycleDuration() time.Duration
- func (m *Styling) OnError(event *es_models.Event, err error) error
- func (m *Styling) OnSuccess() error
- func (h *Styling) QueryLimit() uint64
- func (m *Styling) Reduce(event *es_models.Event) (err error)
- func (m *Styling) Subscription() *v1.Subscription
- func (m *Styling) ViewModel() string
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
Types ¶
type Styling ¶ added in v1.12.0
type Styling struct {
// contains filtered or unexported fields
}
func (*Styling) AggregateTypes ¶ added in v1.12.0
func (_ *Styling) AggregateTypes() []es_models.AggregateType
func (*Styling) CurrentSequence ¶ added in v1.12.0
func (*Styling) EventQuery ¶ added in v1.12.0
func (m *Styling) EventQuery() (*es_models.SearchQuery, error)
func (*Styling) Eventstore ¶ added in v1.12.0
func (h *Styling) Eventstore() v1.Eventstore
func (*Styling) LockDuration ¶ added in v1.12.0
func (*Styling) MinimumCycleDuration ¶ added in v1.12.0
func (*Styling) QueryLimit ¶ added in v1.12.0
func (h *Styling) QueryLimit() uint64
func (*Styling) Subscription ¶ added in v1.19.3
func (m *Styling) Subscription() *v1.Subscription
Click to show internal directories.
Click to hide internal directories.