handler

package
v1.11.0 Latest Latest
Warning

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

 Go to latest Published: Jun 3, 2021 License: Apache-2.0 Imports: 29 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, defaults systemdefaults.SystemDefaults) []query.Handler

Types

type Config 

type Config struct {
	MinimumCycleDuration types.Duration
}

type Configs 

type Configs map[string]*Config

type ExternalIDP added in v0.87.0 

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

func (*ExternalIDP) AggregateTypes added in v0.109.13 

func (i *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) 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) ViewModel added in v0.119.0 

func (p *Features) ViewModel() string

type IAMMember added in v0.109.13 

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

func (*IAMMember) AggregateTypes added in v0.109.13 

func (m *IAMMember) AggregateTypes() []es_models.AggregateType

func (*IAMMember) CurrentSequence added in v0.109.13 

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

func (*IAMMember) EventQuery added in v0.109.13 

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

func (*IAMMember) Eventstore added in v0.109.13 

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

func (*IAMMember) LockDuration added in v0.109.18 

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

func (*IAMMember) MinimumCycleDuration added in v0.109.13 

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

func (*IAMMember) OnError added in v0.109.13 

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

func (*IAMMember) OnSuccess added in v0.109.13 

func (m *IAMMember) OnSuccess() error

func (*IAMMember) QueryLimit added in v0.109.13 

func (h *IAMMember) QueryLimit() uint64

func (*IAMMember) Reduce added in v0.109.13 

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

func (*IAMMember) ViewModel added in v0.109.13 

func (m *IAMMember) ViewModel() string

type IDPConfig added in v0.77.0 

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

func (*IDPConfig) AggregateTypes added in v0.109.13 

func (i *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.77.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.77.0 

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

func (*IDPConfig) OnError added in v0.77.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.77.0 

func (h *IDPConfig) QueryLimit() uint64

func (*IDPConfig) Reduce added in v0.77.0 

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

func (*IDPConfig) ViewModel added in v0.77.0 

func (i *IDPConfig) ViewModel() string

type IDPProvider added in v0.77.0 

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

func (*IDPProvider) AggregateTypes added in v0.109.13 

func (i *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.77.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.77.0 

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

func (*IDPProvider) OnError added in v0.77.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.77.0 

func (h *IDPProvider) QueryLimit() uint64

func (*IDPProvider) Reduce added in v0.77.0 

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

func (*IDPProvider) ViewModel added in v0.77.0 

func (i *IDPProvider) ViewModel() string

type LabelPolicy added in v0.96.0 

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

func (*LabelPolicy) AggregateTypes added in v0.109.13 

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

func (*LabelPolicy) CurrentSequence added in v0.109.13 

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

func (*LabelPolicy) EventQuery added in v0.96.0 

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

func (*LabelPolicy) Eventstore added in v0.109.13 

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

func (*LabelPolicy) LockDuration added in v0.109.18 

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

func (*LabelPolicy) MinimumCycleDuration added in v0.96.0 

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

func (*LabelPolicy) OnError added in v0.96.0 

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

func (*LabelPolicy) OnSuccess added in v0.107.0 

func (p *LabelPolicy) OnSuccess() error

func (*LabelPolicy) QueryLimit added in v0.96.0 

func (h *LabelPolicy) QueryLimit() uint64

func (*LabelPolicy) Reduce added in v0.96.0 

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

func (*LabelPolicy) ViewModel added in v0.96.0 

func (p *LabelPolicy) ViewModel() string

type LoginPolicy added in v0.77.0 

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

func (*LoginPolicy) AggregateTypes added in v0.109.13 

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

func (*LoginPolicy) CurrentSequence added in v0.109.13 

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

func (*LoginPolicy) EventQuery added in v0.77.0 

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

func (*LoginPolicy) Eventstore added in v0.109.13 

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

func (*LoginPolicy) LockDuration added in v0.109.18 

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

func (*LoginPolicy) MinimumCycleDuration added in v0.77.0 

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

func (*LoginPolicy) OnError added in v0.77.0 

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

func (*LoginPolicy) OnSuccess added in v0.107.0 

func (p *LoginPolicy) OnSuccess() error

func (*LoginPolicy) QueryLimit added in v0.77.0 

func (h *LoginPolicy) QueryLimit() uint64

func (*LoginPolicy) Reduce added in v0.77.0 

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

func (*LoginPolicy) ViewModel added in v0.77.0 

func (p *LoginPolicy) ViewModel() string

type MailTemplate added in v0.110.0 

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

func (*MailTemplate) AggregateTypes added in v0.110.0 

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

func (*MailTemplate) CurrentSequence added in v0.110.0 

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

func (*MailTemplate) EventQuery added in v0.110.0 

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

func (*MailTemplate) Eventstore added in v0.110.0 

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

func (*MailTemplate) LockDuration added in v0.110.0 

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

func (*MailTemplate) MinimumCycleDuration added in v0.110.0 

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

func (*MailTemplate) OnError added in v0.110.0 

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

func (*MailTemplate) OnSuccess added in v0.110.0 

func (o *MailTemplate) OnSuccess() error

func (*MailTemplate) QueryLimit added in v0.110.0 

func (h *MailTemplate) QueryLimit() uint64

func (*MailTemplate) Reduce added in v0.110.0 

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

func (*MailTemplate) ViewModel added in v0.110.0 

func (m *MailTemplate) ViewModel() string

type MailText added in v0.110.0 

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

func (*MailText) AggregateTypes added in v0.110.0 

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

func (*MailText) CurrentSequence added in v0.110.0 

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

func (*MailText) EventQuery added in v0.110.0 

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

func (*MailText) Eventstore added in v0.110.0 

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

func (*MailText) LockDuration added in v0.110.0 

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

func (*MailText) MinimumCycleDuration added in v0.110.0 

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

func (*MailText) OnError added in v0.110.0 

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

func (*MailText) OnSuccess added in v0.110.0 

func (o *MailText) OnSuccess() error

func (*MailText) QueryLimit added in v0.110.0 

func (h *MailText) QueryLimit() uint64

func (*MailText) Reduce added in v0.110.0 

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

func (*MailText) ViewModel added in v0.110.0 

func (m *MailText) ViewModel() string

type Org 

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

func (*Org) AggregateTypes added in v0.109.13 

func (o *Org) AggregateTypes() []es_models.AggregateType

func (*Org) CurrentSequence added in v0.109.13 

func (o *Org) CurrentSequence() (uint64, error)

func (*Org) EventQuery 

func (o *Org) EventQuery() (*es_models.SearchQuery, error)

func (*Org) Eventstore added in v0.109.13 

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

func (*Org) LockDuration added in v0.109.18 

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

func (*Org) MinimumCycleDuration 

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

func (*Org) OnError 

func (o *Org) OnError(event *es_models.Event, spoolerErr error) error

func (*Org) OnSuccess added in v0.107.0 

func (o *Org) OnSuccess() error

func (*Org) QueryLimit added in v0.64.4 

func (h *Org) QueryLimit() uint64

func (*Org) Reduce added in v0.33.5 

func (o *Org) Reduce(event *es_models.Event) error

func (*Org) ViewModel 

func (o *Org) ViewModel() string

type OrgIAMPolicy added in v0.92.0 

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

func (*OrgIAMPolicy) AggregateTypes added in v0.109.13 

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

func (*OrgIAMPolicy) CurrentSequence added in v0.109.13 

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

func (*OrgIAMPolicy) EventQuery added in v0.92.0 

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

func (*OrgIAMPolicy) Eventstore added in v0.109.13 

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

func (*OrgIAMPolicy) LockDuration added in v0.109.18 

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

func (*OrgIAMPolicy) MinimumCycleDuration added in v0.92.0 

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

func (*OrgIAMPolicy) OnError added in v0.92.0 

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

func (*OrgIAMPolicy) OnSuccess added in v0.107.0 

func (p *OrgIAMPolicy) OnSuccess() error

func (*OrgIAMPolicy) QueryLimit added in v0.92.0 

func (h *OrgIAMPolicy) QueryLimit() uint64

func (*OrgIAMPolicy) Reduce added in v0.92.0 

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

func (*OrgIAMPolicy) ViewModel added in v0.92.0 

func (p *OrgIAMPolicy) ViewModel() string

type PasswordAgePolicy added in v0.92.0 

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

func (*PasswordAgePolicy) AggregateTypes added in v0.109.13 

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

func (*PasswordAgePolicy) CurrentSequence added in v0.109.13 

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

func (*PasswordAgePolicy) EventQuery added in v0.92.0 

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

func (*PasswordAgePolicy) Eventstore added in v0.109.13 

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

func (*PasswordAgePolicy) LockDuration added in v0.109.18 

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

func (*PasswordAgePolicy) MinimumCycleDuration added in v0.92.0 

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

func (*PasswordAgePolicy) OnError added in v0.92.0 

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

func (*PasswordAgePolicy) OnSuccess added in v0.107.0 

func (p *PasswordAgePolicy) OnSuccess() error

func (*PasswordAgePolicy) QueryLimit added in v0.92.0 

func (h *PasswordAgePolicy) QueryLimit() uint64

func (*PasswordAgePolicy) Reduce added in v0.92.0 

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

func (*PasswordAgePolicy) ViewModel added in v0.92.0 

func (p *PasswordAgePolicy) ViewModel() string

type PasswordComplexityPolicy added in v0.92.0 

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

func (*PasswordComplexityPolicy) AggregateTypes added in v0.109.13 

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

func (*PasswordComplexityPolicy) CurrentSequence added in v0.109.13 

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

func (*PasswordComplexityPolicy) EventQuery added in v0.92.0 

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

func (*PasswordComplexityPolicy) Eventstore added in v0.109.13 

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

func (*PasswordComplexityPolicy) LockDuration added in v0.109.18 

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

func (*PasswordComplexityPolicy) MinimumCycleDuration added in v0.92.0 

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

func (*PasswordComplexityPolicy) OnError added in v0.92.0 

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

func (*PasswordComplexityPolicy) OnSuccess added in v0.107.0 

func (p *PasswordComplexityPolicy) OnSuccess() error

func (*PasswordComplexityPolicy) QueryLimit added in v0.92.0 

func (h *PasswordComplexityPolicy) QueryLimit() uint64

func (*PasswordComplexityPolicy) Reduce added in v0.92.0 

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

func (*PasswordComplexityPolicy) ViewModel added in v0.92.0 

func (p *PasswordComplexityPolicy) ViewModel() string

type PasswordLockoutPolicy added in v0.92.0 

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

func (*PasswordLockoutPolicy) AggregateTypes added in v0.109.13 

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

func (*PasswordLockoutPolicy) CurrentSequence added in v0.109.13 

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

func (*PasswordLockoutPolicy) EventQuery added in v0.92.0 

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

func (*PasswordLockoutPolicy) Eventstore added in v0.109.13 

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

func (*PasswordLockoutPolicy) LockDuration added in v0.109.18 

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

func (*PasswordLockoutPolicy) MinimumCycleDuration added in v0.92.0 

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

func (*PasswordLockoutPolicy) OnError added in v0.92.0 

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

func (*PasswordLockoutPolicy) OnSuccess added in v0.107.0 

func (p *PasswordLockoutPolicy) OnSuccess() error

func (*PasswordLockoutPolicy) QueryLimit added in v0.92.0 

func (h *PasswordLockoutPolicy) QueryLimit() uint64

func (*PasswordLockoutPolicy) Reduce added in v0.92.0 

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

func (*PasswordLockoutPolicy) ViewModel added in v0.92.0 

func (p *PasswordLockoutPolicy) ViewModel() string

type User added in v0.74.4 

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

func (*User) AggregateTypes added in v0.109.13 

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

func (*User) CurrentSequence added in v0.109.13 

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

func (*User) EventQuery added in v0.74.4 

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 added in v0.74.4 

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

func (*User) OnError added in v0.74.4 

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.74.4 

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

func (*User) ProcessUser added in v0.74.4 

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

func (*User) QueryLimit added in v0.74.4 

func (h *User) QueryLimit() uint64

func (*User) Reduce added in v0.74.4 

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

func (*User) ViewModel added in v0.74.4 

func (u *User) 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.