handler

package
v0.0.0-...-860e413 Latest Latest
Warning

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

Go to latest
Published: Oct 21, 2022 License: Apache-2.0 Imports: 21 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, static static.Storage) []query.Handler

Types

type Config

type Config struct {
	MinimumCycleDuration time.Duration
}

type Configs

type Configs map[string]*Config

type Styling

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

func (*Styling) AggregateTypes

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

func (*Styling) CurrentSequence

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

func (*Styling) EventQuery

func (m *Styling) EventQuery(instanceIDs ...string) (*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 *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 *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