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
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
Types ¶
type UserGrant ¶
type UserGrant struct {
// contains filtered or unexported fields
}
func (*UserGrant) AggregateTypes ¶
func (_ *UserGrant) AggregateTypes() []es_models.AggregateType
func (*UserGrant) CurrentSequence ¶
func (*UserGrant) EventQuery ¶
func (u *UserGrant) EventQuery() (*es_models.SearchQuery, error)
func (*UserGrant) Eventstore ¶
func (h *UserGrant) Eventstore() v1.Eventstore
func (*UserGrant) LockDuration ¶
func (*UserGrant) MinimumCycleDuration ¶
func (*UserGrant) QueryLimit ¶
func (h *UserGrant) QueryLimit() uint64
func (*UserGrant) Subscription ¶
func (u *UserGrant) Subscription() *v1.Subscription
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 (*UserMembership) MinimumCycleDuration ¶
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) Subscription ¶
func (m *UserMembership) Subscription() *v1.Subscription
func (*UserMembership) ViewModel ¶
func (m *UserMembership) ViewModel() string
Click to show internal directories.
Click to hide internal directories.