handler

Documentation

Index

• func Register(configs Configs, bulkLimit, errorCount uint64, view *view.View, ...) []query.Handler
• type Config
• type Configs
• type Styling
  • func (_ *Styling) AggregateTypes() []models.AggregateType
  • func (m *Styling) CurrentSequence(instanceID string) (uint64, error)
  • func (m *Styling) EventQuery() (*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 *models.Event, err error) error
  • func (m *Styling) OnSuccess() error
  • func (h *Styling) QueryLimit() uint64
  • func (m *Styling) Reduce(event *models.Event) (err error)
  • func (m *Styling) Subscription() *v1.Subscription
  • func (m *Styling) ViewModel() string

Functions

func Register

func Register(configs Configs, bulkLimit, errorCount uint64, view *view.View, es v1.Eventstore, static static.Storage, loginPrefix string) []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() (*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