handler

package
v1.87.5 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Dec 20, 2022 License: Apache-2.0 Imports: 22 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func Register

func Register(configs Configs, bulkLimit, errorCount uint64, view *view.View, es v1.Eventstore, defaults systemdefaults.SystemDefaults, command *command.Commands, static static.Storage, localDevMode bool) []query.Handler

Types

type Config

type Config struct {
	MinimumCycleDuration types.Duration
}

type Configs

type Configs map[string]*Config

type Styling

type Styling struct {
	// contains filtered or unexported fields
}

func (*Styling) AggregateTypes

func (_ *Styling) AggregateTypes() []es_models.AggregateType

func (*Styling) CurrentSequence

func (m *Styling) CurrentSequence() (uint64, error)

func (*Styling) EventQuery

func (m *Styling) EventQuery() (*es_models.SearchQuery, error)

func (*Styling) Eventstore

func (h *Styling) Eventstore() v1.Eventstore

func (*Styling) LockDuration

func (h *Styling) LockDuration() time.Duration

func (*Styling) MinimumCycleDuration

func (h *Styling) MinimumCycleDuration() time.Duration

func (*Styling) OnError

func (m *Styling) OnError(event *es_models.Event, err error) error

func (*Styling) OnSuccess

func (m *Styling) OnSuccess() error

func (*Styling) QueryLimit

func (h *Styling) QueryLimit() uint64

func (*Styling) Reduce

func (m *Styling) Reduce(event *es_models.Event) (err error)

func (*Styling) Subscription

func (m *Styling) Subscription() *v1.Subscription

func (*Styling) ViewModel

func (m *Styling) ViewModel() string

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL