handler

package
v1.50.0 Latest Latest
Warning

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

 Go to latest Published: Oct 28, 2021 License: Apache-2.0 Imports: 43 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, systemDefaults sd.SystemDefaults, keyChan chan<- *key_model.KeyView) []query.Handler

Types

type Application added in v0.20.0 

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

func (*Application) AggregateTypes added in v0.109.13 

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

func (*Application) CurrentSequence added in v0.109.13 

func (a *Application) CurrentSequence() (uint64, error)

func (*Application) EventQuery added in v0.20.0 

func (a *Application) EventQuery() (*models.SearchQuery, error)

func (*Application) Eventstore added in v0.109.13 

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

func (*Application) LockDuration added in v0.109.18 

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

func (*Application) MinimumCycleDuration added in v0.20.0 

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

func (*Application) OnError added in v0.20.0 

func (a *Application) OnError(event *models.Event, spoolerError error) error

func (*Application) OnSuccess added in v0.107.0 

func (a *Application) OnSuccess() error

func (*Application) QueryLimit added in v0.64.4 

func (h *Application) QueryLimit() uint64

func (*Application) Reduce added in v0.33.5 

func (a *Application) Reduce(event *models.Event) (err error)

func (*Application) Subscription added in v1.19.3 

func (a *Application) Subscription() *v1.Subscription

func (*Application) ViewModel added in v0.20.0 

func (a *Application) ViewModel() string

type AuthNKeys added in v0.115.0 

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

func (*AuthNKeys) AggregateTypes added in v0.115.0 

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

func (*AuthNKeys) CurrentSequence added in v0.115.0 

func (k *AuthNKeys) CurrentSequence() (uint64, error)

func (*AuthNKeys) EventQuery added in v0.115.0 

func (k *AuthNKeys) EventQuery() (*es_models.SearchQuery, error)

func (*AuthNKeys) Eventstore added in v0.115.0 

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

func (*AuthNKeys) LockDuration added in v0.115.0 

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

func (*AuthNKeys) MinimumCycleDuration added in v0.115.0 

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

func (*AuthNKeys) OnError added in v0.115.0 

func (k *AuthNKeys) OnError(event *es_models.Event, err error) error

func (*AuthNKeys) OnSuccess added in v0.115.0 

func (k *AuthNKeys) OnSuccess() error

func (*AuthNKeys) QueryLimit added in v0.115.0 

func (h *AuthNKeys) QueryLimit() uint64

func (*AuthNKeys) Reduce added in v0.115.0 

func (k *AuthNKeys) Reduce(event *es_models.Event) (err error)

func (*AuthNKeys) Subscription added in v1.19.3 

func (k *AuthNKeys) Subscription() *v1.Subscription

func (*AuthNKeys) ViewModel added in v0.115.0 

func (k *AuthNKeys) ViewModel() string

type Config 

type Config struct {
	MinimumCycleDuration types.Duration
}

type Configs 

type Configs map[string]*Config

type CustomText added in v1.19.0 

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

func (*CustomText) AggregateTypes added in v1.19.0 

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

func (*CustomText) CurrentSequence added in v1.19.0 

func (p *CustomText) CurrentSequence() (uint64, error)

func (*CustomText) EventQuery added in v1.19.0 

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

func (*CustomText) Eventstore added in v1.19.0 

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

func (*CustomText) LockDuration added in v1.19.0 

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

func (*CustomText) MinimumCycleDuration added in v1.19.0 

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

func (*CustomText) OnError added in v1.19.0 

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

func (*CustomText) OnSuccess added in v1.19.0 

func (o *CustomText) OnSuccess() error

func (*CustomText) QueryLimit added in v1.19.0 

func (h *CustomText) QueryLimit() uint64

func (*CustomText) Reduce added in v1.19.0 

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

func (*CustomText) Subscription added in v1.19.3 

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

func (*CustomText) ViewModel added in v1.19.0 

func (m *CustomText) ViewModel() string

type ExternalIDP added in v0.87.0 

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

func (*ExternalIDP) AggregateTypes added in v0.109.13 

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

func (*ExternalIDP) CurrentSequence added in v0.109.13 

func (i *ExternalIDP) CurrentSequence() (uint64, error)

func (*ExternalIDP) EventQuery added in v0.87.0 

func (i *ExternalIDP) EventQuery() (*es_models.SearchQuery, error)

func (*ExternalIDP) Eventstore added in v0.109.13 

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

func (*ExternalIDP) LockDuration added in v0.109.18 

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

func (*ExternalIDP) MinimumCycleDuration added in v0.87.0 

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

func (*ExternalIDP) OnError added in v0.87.0 

func (i *ExternalIDP) OnError(event *es_models.Event, err error) error

func (*ExternalIDP) OnSuccess added in v0.107.0 

func (i *ExternalIDP) OnSuccess() error

func (*ExternalIDP) QueryLimit added in v0.87.0 

func (h *ExternalIDP) QueryLimit() uint64

func (*ExternalIDP) Reduce added in v0.87.0 

func (i *ExternalIDP) Reduce(event *es_models.Event) (err error)

func (*ExternalIDP) Subscription added in v1.19.3 

func (i *ExternalIDP) Subscription() *v1.Subscription

func (*ExternalIDP) ViewModel added in v0.87.0 

func (i *ExternalIDP) ViewModel() string

type Features added in v0.119.0 

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

func (*Features) AggregateTypes added in v0.119.0 

func (p *Features) AggregateTypes() []es_models.AggregateType

func (*Features) CurrentSequence added in v0.119.0 

func (p *Features) CurrentSequence() (uint64, error)

func (*Features) EventQuery added in v0.119.0 

func (p *Features) EventQuery() (*es_models.SearchQuery, error)

func (*Features) Eventstore added in v0.119.0 

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

func (*Features) LockDuration added in v0.119.0 

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

func (*Features) MinimumCycleDuration added in v0.119.0 

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

func (*Features) OnError added in v0.119.0 

func (p *Features) OnError(event *es_models.Event, err error) error

func (*Features) OnSuccess added in v0.119.0 

func (p *Features) OnSuccess() error

func (*Features) QueryLimit added in v0.119.0 

func (h *Features) QueryLimit() uint64

func (*Features) Reduce added in v0.119.0 

func (p *Features) Reduce(event *es_models.Event) (err error)

func (*Features) Subscription added in v1.19.3 

func (p *Features) Subscription() *v1.Subscription

func (*Features) ViewModel added in v0.119.0 

func (p *Features) ViewModel() string

type IDPConfig added in v0.87.0 

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

func (*IDPConfig) AggregateTypes added in v0.109.13 

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

func (*IDPConfig) CurrentSequence added in v0.109.13 

func (i *IDPConfig) CurrentSequence() (uint64, error)

func (*IDPConfig) EventQuery added in v0.87.0 

func (i *IDPConfig) EventQuery() (*es_models.SearchQuery, error)

func (*IDPConfig) Eventstore added in v0.109.13 

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

func (*IDPConfig) LockDuration added in v0.109.18 

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

func (*IDPConfig) MinimumCycleDuration added in v0.87.0 

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

func (*IDPConfig) OnError added in v0.87.0 

func (i *IDPConfig) OnError(event *es_models.Event, err error) error

func (*IDPConfig) OnSuccess added in v0.107.0 

func (i *IDPConfig) OnSuccess() error

func (*IDPConfig) QueryLimit added in v0.87.0 

func (h *IDPConfig) QueryLimit() uint64

func (*IDPConfig) Reduce added in v0.87.0 

func (i *IDPConfig) Reduce(event *es_models.Event) (err error)

func (*IDPConfig) Subscription added in v1.19.3 

func (i *IDPConfig) Subscription() *v1.Subscription

func (*IDPConfig) ViewModel added in v0.87.0 

func (i *IDPConfig) ViewModel() string

type IDPProvider added in v0.87.0 

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

func (*IDPProvider) AggregateTypes added in v0.109.13 

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

func (*IDPProvider) CurrentSequence added in v0.109.13 

func (i *IDPProvider) CurrentSequence() (uint64, error)

func (*IDPProvider) EventQuery added in v0.87.0 

func (i *IDPProvider) EventQuery() (*es_models.SearchQuery, error)

func (*IDPProvider) Eventstore added in v0.109.13 

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

func (*IDPProvider) LockDuration added in v0.109.18 

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

func (*IDPProvider) MinimumCycleDuration added in v0.87.0 

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

func (*IDPProvider) OnError added in v0.87.0 

func (i *IDPProvider) OnError(event *es_models.Event, err error) error

func (*IDPProvider) OnSuccess added in v0.107.0 

func (i *IDPProvider) OnSuccess() error

func (*IDPProvider) QueryLimit added in v0.87.0 

func (h *IDPProvider) QueryLimit() uint64

func (*IDPProvider) Reduce added in v0.87.0 

func (i *IDPProvider) Reduce(event *es_models.Event) (err error)

func (*IDPProvider) Subscription added in v1.19.3 

func (i *IDPProvider) Subscription() *v1.Subscription

func (*IDPProvider) ViewModel added in v0.87.0 

func (i *IDPProvider) ViewModel() string

type Key added in v0.20.0 

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

func (*Key) AggregateTypes added in v0.109.13 

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

func (*Key) CurrentSequence added in v0.109.13 

func (k *Key) CurrentSequence() (uint64, error)

func (*Key) EventQuery added in v0.20.0 

func (k *Key) EventQuery() (*models.SearchQuery, error)

func (*Key) Eventstore added in v0.109.13 

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

func (*Key) LockDuration added in v0.109.18 

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

func (*Key) MinimumCycleDuration added in v0.20.0 

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

func (*Key) OnError added in v0.20.0 

func (k *Key) OnError(event *models.Event, err error) error

func (*Key) OnSuccess added in v0.107.0 

func (k *Key) OnSuccess() error

func (*Key) QueryLimit added in v0.64.4 

func (h *Key) QueryLimit() uint64

func (*Key) Reduce added in v0.33.5 

func (k *Key) Reduce(event *models.Event) error

func (*Key) Subscription added in v1.19.3 

func (k *Key) Subscription() *v1.Subscription

func (*Key) ViewModel added in v0.20.0 

func (k *Key) ViewModel() string

type LabelPolicy added in v0.118.0 

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

func (*LabelPolicy) AggregateTypes added in v0.118.0 

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

func (*LabelPolicy) CurrentSequence added in v0.118.0 

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

func (*LabelPolicy) EventQuery added in v0.118.0 

func (m *LabelPolicy) EventQuery() (*models.SearchQuery, error)

func (*LabelPolicy) Eventstore added in v0.118.0 

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

func (*LabelPolicy) LockDuration added in v0.118.0 

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

func (*LabelPolicy) MinimumCycleDuration added in v0.118.0 

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

func (*LabelPolicy) OnError added in v0.118.0 

func (m *LabelPolicy) OnError(event *models.Event, err error) error

func (*LabelPolicy) OnSuccess added in v0.118.0 

func (m *LabelPolicy) OnSuccess() error

func (*LabelPolicy) QueryLimit added in v0.118.0 

func (h *LabelPolicy) QueryLimit() uint64

func (*LabelPolicy) Reduce added in v0.118.0 

func (m *LabelPolicy) Reduce(event *models.Event) (err error)

func (*LabelPolicy) Subscription added in v1.19.3 

func (p *LabelPolicy) Subscription() *v1.Subscription

func (*LabelPolicy) ViewModel added in v0.118.0 

func (m *LabelPolicy) ViewModel() string

type Metadata added in v1.29.0 

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

func (*Metadata) AggregateTypes added in v1.29.0 

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

func (*Metadata) CurrentSequence added in v1.29.0 

func (p *Metadata) CurrentSequence() (uint64, error)

func (*Metadata) EventQuery added in v1.29.0 

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

func (*Metadata) Eventstore added in v1.29.0 

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

func (*Metadata) LockDuration added in v1.29.0 

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

func (*Metadata) MinimumCycleDuration added in v1.29.0 

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

func (*Metadata) OnError added in v1.29.0 

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

func (*Metadata) OnSuccess added in v1.29.0 

func (m *Metadata) OnSuccess() error

func (*Metadata) QueryLimit added in v1.29.0 

func (h *Metadata) QueryLimit() uint64

func (*Metadata) Reduce added in v1.29.0 

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

func (*Metadata) Subscription added in v1.29.0 

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

func (*Metadata) ViewModel added in v1.29.0 

func (m *Metadata) ViewModel() string

type OrgProjectMapping added in v1.30.0 

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

func (*OrgProjectMapping) AggregateTypes added in v1.30.0 

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

func (*OrgProjectMapping) CurrentSequence added in v1.30.0 

func (p *OrgProjectMapping) CurrentSequence() (uint64, error)

func (*OrgProjectMapping) EventQuery added in v1.30.0 

func (p *OrgProjectMapping) EventQuery() (*es_models.SearchQuery, error)

func (*OrgProjectMapping) Eventstore added in v1.30.0 

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

func (*OrgProjectMapping) LockDuration added in v1.30.0 

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

func (*OrgProjectMapping) MinimumCycleDuration added in v1.30.0 

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

func (*OrgProjectMapping) OnError added in v1.30.0 

func (p *OrgProjectMapping) OnError(event *es_models.Event, err error) error

func (*OrgProjectMapping) OnSuccess added in v1.30.0 

func (p *OrgProjectMapping) OnSuccess() error

func (*OrgProjectMapping) QueryLimit added in v1.30.0 

func (h *OrgProjectMapping) QueryLimit() uint64

func (*OrgProjectMapping) Reduce added in v1.30.0 

func (p *OrgProjectMapping) Reduce(event *es_models.Event) (err error)

func (*OrgProjectMapping) Subscription added in v1.30.0 

func (p *OrgProjectMapping) Subscription() *v1.Subscription

func (*OrgProjectMapping) ViewModel added in v1.30.0 

func (p *OrgProjectMapping) ViewModel() string

type ProjectRole added in v0.94.0 

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

func (*ProjectRole) AggregateTypes added in v0.109.13 

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

func (*ProjectRole) CurrentSequence added in v0.109.13 

func (p *ProjectRole) CurrentSequence() (uint64, error)

func (*ProjectRole) EventQuery added in v0.94.0 

func (p *ProjectRole) EventQuery() (*es_models.SearchQuery, error)

func (*ProjectRole) Eventstore added in v0.109.13 

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

func (*ProjectRole) LockDuration added in v0.109.18 

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

func (*ProjectRole) MinimumCycleDuration added in v0.94.0 

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

func (*ProjectRole) OnError added in v0.94.0 

func (p *ProjectRole) OnError(event *es_models.Event, err error) error

func (*ProjectRole) OnSuccess added in v0.107.0 

func (p *ProjectRole) OnSuccess() error

func (*ProjectRole) QueryLimit added in v0.94.0 

func (h *ProjectRole) QueryLimit() uint64

func (*ProjectRole) Reduce added in v0.94.0 

func (p *ProjectRole) Reduce(event *es_models.Event) (err error)

func (*ProjectRole) Subscription added in v1.19.3 

func (p *ProjectRole) Subscription() *v1.Subscription

func (*ProjectRole) ViewModel added in v0.94.0 

func (p *ProjectRole) ViewModel() string

type RefreshToken added in v1.8.0 

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

func (*RefreshToken) AggregateTypes added in v1.8.0 

func (t *RefreshToken) AggregateTypes() []es_models.AggregateType

func (*RefreshToken) CurrentSequence added in v1.8.0 

func (t *RefreshToken) CurrentSequence() (uint64, error)

func (*RefreshToken) EventQuery added in v1.8.0 

func (t *RefreshToken) EventQuery() (*es_models.SearchQuery, error)

func (*RefreshToken) Eventstore added in v1.8.0 

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

func (*RefreshToken) LockDuration added in v1.8.0 

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

func (*RefreshToken) MinimumCycleDuration added in v1.8.0 

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

func (*RefreshToken) OnError added in v1.8.0 

func (t *RefreshToken) OnError(event *es_models.Event, err error) error

func (*RefreshToken) OnSuccess added in v1.8.0 

func (t *RefreshToken) OnSuccess() error

func (*RefreshToken) QueryLimit added in v1.8.0 

func (h *RefreshToken) QueryLimit() uint64

func (*RefreshToken) Reduce added in v1.8.0 

func (t *RefreshToken) Reduce(event *es_models.Event) (err error)

func (*RefreshToken) Subscription added in v1.19.3 

func (t *RefreshToken) Subscription() *v1.Subscription

func (*RefreshToken) ViewModel added in v1.8.0 

func (t *RefreshToken) ViewModel() string

type Token 

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

func (*Token) AggregateTypes added in v0.109.13 

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

func (*Token) CurrentSequence added in v0.109.13 

func (p *Token) CurrentSequence() (uint64, error)

func (*Token) EventQuery 

func (t *Token) EventQuery() (*es_models.SearchQuery, error)

func (*Token) Eventstore added in v0.109.13 

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

func (*Token) LockDuration added in v0.109.18 

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

func (*Token) MinimumCycleDuration 

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

func (*Token) OnError 

func (t *Token) OnError(event *es_models.Event, err error) error

func (*Token) OnSuccess added in v0.107.0 

func (t *Token) OnSuccess() error

func (*Token) QueryLimit added in v0.64.4 

func (h *Token) QueryLimit() uint64

func (*Token) Reduce added in v0.33.5 

func (t *Token) Reduce(event *es_models.Event) (err error)

func (*Token) Subscription added in v1.19.3 

func (t *Token) Subscription() *v1.Subscription

func (*Token) ViewModel 

func (t *Token) ViewModel() string

type User 

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

func (*User) AggregateTypes added in v0.109.13 

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

func (*User) CurrentSequence added in v0.109.13 

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

func (*User) EventQuery 

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

func (*User) Eventstore added in v0.109.13 

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

func (*User) LockDuration added in v0.109.18 

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

func (*User) MinimumCycleDuration 

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

func (*User) OnError 

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

func (*User) OnSuccess added in v0.107.0 

func (u *User) OnSuccess() error

func (*User) ProcessOrg added in v0.26.0 

func (u *User) ProcessOrg(event *es_models.Event) (err error)

func (*User) ProcessUser added in v0.26.0 

func (u *User) ProcessUser(event *es_models.Event) (err error)

func (*User) QueryLimit added in v0.64.4 

func (h *User) QueryLimit() uint64

func (*User) Reduce added in v0.33.5 

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

func (*User) Subscription added in v1.19.3 

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

func (*User) ViewModel 

func (u *User) ViewModel() string

type UserGrant added in v0.20.0 

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

func (*UserGrant) AggregateTypes added in v0.109.13 

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

func (*UserGrant) CurrentSequence added in v0.109.13 

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

func (*UserGrant) EventQuery added in v0.20.0 

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

func (*UserGrant) Eventstore added in v0.109.13 

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

func (*UserGrant) LockDuration added in v0.109.18 

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

func (*UserGrant) MinimumCycleDuration added in v0.20.0 

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

func (*UserGrant) OnError added in v0.20.0 

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

func (*UserGrant) OnSuccess added in v0.107.0 

func (u *UserGrant) OnSuccess() error

func (*UserGrant) QueryLimit added in v0.64.4 

func (h *UserGrant) QueryLimit() uint64

func (*UserGrant) Reduce added in v0.33.5 

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

func (*UserGrant) Subscription added in v1.19.3 

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

func (*UserGrant) ViewModel added in v0.20.0 

func (u *UserGrant) ViewModel() string

type UserMembership added in v0.82.4 

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

func (*UserMembership) AggregateTypes added in v0.109.13 

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

func (*UserMembership) CurrentSequence added in v0.109.13 

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

func (*UserMembership) EventQuery added in v0.82.4 

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

func (*UserMembership) Eventstore added in v0.109.13 

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

func (*UserMembership) LockDuration added in v0.109.18 

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

func (*UserMembership) MinimumCycleDuration added in v0.82.4 

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

func (*UserMembership) OnError added in v0.82.4 

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

func (*UserMembership) OnSuccess added in v0.107.0 

func (m *UserMembership) OnSuccess() error

func (*UserMembership) QueryLimit added in v0.82.4 

func (h *UserMembership) QueryLimit() uint64

func (*UserMembership) Reduce added in v0.82.4 

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

func (*UserMembership) Subscription added in v1.19.3 

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

func (*UserMembership) ViewModel added in v0.82.4 

func (m *UserMembership) ViewModel() string

type UserSession 

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

func (*UserSession) AggregateTypes added in v0.109.13 

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

func (*UserSession) CurrentSequence added in v0.109.13 

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

func (*UserSession) EventQuery 

func (u *UserSession) EventQuery() (*models.SearchQuery, error)

func (*UserSession) Eventstore added in v0.109.13 

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

func (*UserSession) LockDuration added in v0.109.18 

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

func (*UserSession) MinimumCycleDuration 

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

func (*UserSession) OnError 

func (u *UserSession) OnError(event *models.Event, err error) error

func (*UserSession) OnSuccess added in v0.107.0 

func (u *UserSession) OnSuccess() error

func (*UserSession) QueryLimit added in v0.64.4 

func (h *UserSession) QueryLimit() uint64

func (*UserSession) Reduce added in v0.33.5 

func (u *UserSession) Reduce(event *models.Event) (err error)

func (*UserSession) Subscription added in v1.19.3 

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

func (*UserSession) ViewModel 

func (u *UserSession) ViewModel() string

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.