handler

Documentation

Index

• func Register(configs Configs, bulkLimit, errorCount uint64, view *view.View, ...) []query.Handler
• type Config
• type Configs
• type UserGrant
  • func (_ *UserGrant) AggregateTypes() []es_models.AggregateType
  • func (u *UserGrant) CurrentSequence() (uint64, error)
  • func (u *UserGrant) EventQuery() (*es_models.SearchQuery, error)
  • func (h *UserGrant) Eventstore() v1.Eventstore
  • func (h *UserGrant) LockDuration() time.Duration
  • func (h *UserGrant) MinimumCycleDuration() time.Duration
  • func (u *UserGrant) OnError(event *es_models.Event, err error) error
  • func (u *UserGrant) OnSuccess() error
  • func (h *UserGrant) QueryLimit() uint64
  • func (u *UserGrant) Reduce(event *es_models.Event) (err error)
  • func (u *UserGrant) Subscription() *v1.Subscription
  • func (u *UserGrant) ViewModel() string
• type UserMembership
  • func (_ *UserMembership) AggregateTypes() []es_models.AggregateType
  • func (m *UserMembership) CurrentSequence() (uint64, error)
  • func (m *UserMembership) EventQuery() (*es_models.SearchQuery, error)
  • func (h *UserMembership) Eventstore() v1.Eventstore
  • func (h *UserMembership) LockDuration() time.Duration
  • func (h *UserMembership) MinimumCycleDuration() time.Duration
  • func (m *UserMembership) OnError(event *es_models.Event, err error) error
  • func (m *UserMembership) OnSuccess() error
  • func (h *UserMembership) QueryLimit() uint64
  • func (m *UserMembership) Reduce(event *es_models.Event) (err error)
  • func (m *UserMembership) Subscription() *v1.Subscription
  • func (m *UserMembership) ViewModel() string

Functions

func Register

func Register(configs Configs, bulkLimit, errorCount uint64, view *view.View, es v1.Eventstore, systemDefaults sd.SystemDefaults) []query.Handler

Types

type Config

type Config struct {
	MinimumCycleDuration types.Duration
}

type Configs

type Configs map[string]*Config

type UserGrant

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

func (*UserGrant) AggregateTypes

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

func (*UserGrant) CurrentSequence

func (u *UserGrant) CurrentSequence() (uint64, error)

func (*UserGrant) EventQuery

func (u *UserGrant) EventQuery() (*es_models.SearchQuery, error)

func (*UserGrant) Eventstore

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

func (*UserGrant) LockDuration

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

func (*UserGrant) MinimumCycleDuration

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

func (*UserGrant) OnError

func (u *UserGrant) OnError(event *es_models.Event, err error) error

func (*UserGrant) OnSuccess

func (u *UserGrant) OnSuccess() error

func (*UserGrant) QueryLimit

func (h *UserGrant) QueryLimit() uint64

func (*UserGrant) Reduce

func (u *UserGrant) Reduce(event *es_models.Event) (err error)

func (*UserGrant) Subscription

func (u *UserGrant) Subscription() *v1.Subscription

func (*UserGrant) ViewModel

func (u *UserGrant) ViewModel() string

type UserMembership

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

func (*UserMembership) AggregateTypes

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

func (*UserMembership) CurrentSequence

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

func (*UserMembership) EventQuery

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

func (*UserMembership) Eventstore

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

func (*UserMembership) LockDuration

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

func (*UserMembership) MinimumCycleDuration

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

func (*UserMembership) OnError

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

func (*UserMembership) OnSuccess

func (m *UserMembership) OnSuccess() error

func (*UserMembership) QueryLimit

func (h *UserMembership) QueryLimit() uint64

func (*UserMembership) Reduce

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

func (*UserMembership) Subscription

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

func (*UserMembership) ViewModel

func (m *UserMembership) ViewModel() string