handler

package
v1.42.0 Latest Latest
Warning

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

 Go to latest Published: Sep 27, 2021 License: Apache-2.0 Imports: 38 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, staticStorage static.Storage) []query.Handler

Types

type Application 

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 

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 

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

func (*Application) OnError 

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 

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 (d *AuthNKeys) OnError(event *es_models.Event, err error) error

func (*AuthNKeys) OnSuccess added in v0.115.0 

func (d *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.77.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 (m *IDPConfig) CurrentSequence() (uint64, error)

func (*IDPConfig) EventQuery added in v0.77.0 

func (m *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 (m *IDPConfig) Reduce(event *es_models.Event) (err error)

func (*IDPConfig) Subscription added in v1.19.3 

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

func (*IDPConfig) ViewModel added in v0.77.0 

func (m *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 (_ *IDPProvider) AggregateTypes() []es_models.AggregateType

func (*IDPProvider) CurrentSequence added in v0.109.13 

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

func (*IDPProvider) EventQuery added in v0.77.0 

func (m *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 (m *IDPProvider) OnError(event *es_models.Event, err error) error

func (*IDPProvider) OnSuccess added in v0.107.0 

func (m *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 (m *IDPProvider) Reduce(event *es_models.Event) (err error)

func (*IDPProvider) Subscription added in v1.19.3 

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

func (*IDPProvider) ViewModel added in v0.77.0 

func (m *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 (_ *LabelPolicy) AggregateTypes() []es_models.AggregateType

func (*LabelPolicy) CleanUpBucket added in v1.12.0 

func (p *LabelPolicy) CleanUpBucket(policy *iam_model.LabelPolicyView)

func (*LabelPolicy) CurrentSequence added in v0.109.13 

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

func (*LabelPolicy) EventQuery added in v0.96.0 

func (m *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 (m *LabelPolicy) OnError(event *es_models.Event, err error) error

func (*LabelPolicy) OnSuccess added in v0.107.0 

func (m *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 (m *LabelPolicy) Reduce(event *es_models.Event) (err error)

func (*LabelPolicy) Subscription added in v1.19.3 

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

func (*LabelPolicy) ViewModel added in v0.96.0 

func (m *LabelPolicy) ViewModel() string

type LockoutPolicy added in v1.29.0 

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

func (*LockoutPolicy) AggregateTypes added in v1.29.0 

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

func (*LockoutPolicy) CurrentSequence added in v1.29.0 

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

func (*LockoutPolicy) EventQuery added in v1.29.0 

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

func (*LockoutPolicy) Eventstore added in v1.29.0 

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

func (*LockoutPolicy) LockDuration added in v1.29.0 

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

func (*LockoutPolicy) MinimumCycleDuration added in v1.29.0 

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

func (*LockoutPolicy) OnError added in v1.29.0 

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

func (*LockoutPolicy) OnSuccess added in v1.29.0 

func (p *LockoutPolicy) OnSuccess() error

func (*LockoutPolicy) QueryLimit added in v1.29.0 

func (h *LockoutPolicy) QueryLimit() uint64

func (*LockoutPolicy) Reduce added in v1.29.0 

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

func (*LockoutPolicy) Subscription added in v1.29.0 

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

func (*LockoutPolicy) ViewModel added in v1.29.0 

func (p *LockoutPolicy) 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 (_ *LoginPolicy) AggregateTypes() []es_models.AggregateType

func (*LoginPolicy) CurrentSequence added in v0.109.13 

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

func (*LoginPolicy) EventQuery added in v0.77.0 

func (m *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 (m *LoginPolicy) OnError(event *es_models.Event, err error) error

func (*LoginPolicy) OnSuccess added in v0.107.0 

func (m *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 (m *LoginPolicy) Reduce(event *es_models.Event) (err error)

func (*LoginPolicy) Subscription added in v1.19.3 

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

func (*LoginPolicy) ViewModel added in v0.77.0 

func (m *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) Subscription added in v1.19.3 

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

func (*MailTemplate) ViewModel added in v0.110.0 

func (m *MailTemplate) ViewModel() string

type MessageText added in v1.13.0 

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

func (*MessageText) AggregateTypes added in v1.13.0 

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

func (*MessageText) CurrentSequence added in v1.13.0 

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

func (*MessageText) EventQuery added in v1.13.0 

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

func (*MessageText) Eventstore added in v1.13.0 

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

func (*MessageText) LockDuration added in v1.13.0 

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

func (*MessageText) MinimumCycleDuration added in v1.13.0 

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

func (*MessageText) OnError added in v1.13.0 

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

func (*MessageText) OnSuccess added in v1.13.0 

func (o *MessageText) OnSuccess() error

func (*MessageText) QueryLimit added in v1.13.0 

func (h *MessageText) QueryLimit() uint64

func (*MessageText) Reduce added in v1.13.0 

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

func (*MessageText) Subscription added in v1.19.3 

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

func (*MessageText) ViewModel added in v1.13.0 

func (m *MessageText) 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 (o *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 Org added in v0.18.0 

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

func (*Org) AggregateTypes added in v0.109.13 

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

func (*Org) CurrentSequence added in v0.109.13 

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

func (*Org) EventQuery added in v0.18.0 

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

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

func (*Org) OnError added in v0.18.0 

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) (err error)

func (*Org) Subscription added in v1.19.3 

func (o *Org) Subscription() *v1.Subscription

func (*Org) ViewModel added in v0.18.0 

func (o *Org) ViewModel() string

type OrgDomain added in v0.26.0 

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

func (*OrgDomain) AggregateTypes added in v0.109.13 

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

func (*OrgDomain) CurrentSequence added in v0.109.13 

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

func (*OrgDomain) EventQuery added in v0.26.0 

func (d *OrgDomain) EventQuery() (*es_models.SearchQuery, error)

func (*OrgDomain) Eventstore added in v0.109.13 

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

func (*OrgDomain) LockDuration added in v0.109.18 

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

func (*OrgDomain) MinimumCycleDuration added in v0.26.0 

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

func (*OrgDomain) OnError added in v0.26.0 

func (d *OrgDomain) OnError(event *es_models.Event, err error) error

func (*OrgDomain) OnSuccess added in v0.107.0 

func (o *OrgDomain) OnSuccess() error

func (*OrgDomain) QueryLimit added in v0.64.4 

func (h *OrgDomain) QueryLimit() uint64

func (*OrgDomain) Reduce added in v0.33.5 

func (d *OrgDomain) Reduce(event *es_models.Event) (err error)

func (*OrgDomain) Subscription added in v1.19.3 

func (d *OrgDomain) Subscription() *v1.Subscription

func (*OrgDomain) ViewModel added in v0.26.0 

func (d *OrgDomain) 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 (_ *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 (m *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 (m *OrgIAMPolicy) OnError(event *es_models.Event, err error) error

func (*OrgIAMPolicy) OnSuccess added in v0.107.0 

func (o *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 (m *OrgIAMPolicy) Reduce(event *es_models.Event) (err error)

func (*OrgIAMPolicy) Subscription added in v1.19.3 

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

func (*OrgIAMPolicy) ViewModel added in v0.92.0 

func (m *OrgIAMPolicy) ViewModel() string

type OrgMember added in v0.18.0 

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

func (*OrgMember) AggregateTypes added in v0.109.13 

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

func (*OrgMember) CurrentSequence added in v0.109.13 

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

func (*OrgMember) EventQuery added in v0.18.0 

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

func (*OrgMember) Eventstore added in v0.109.13 

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

func (*OrgMember) LockDuration added in v0.109.18 

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

func (*OrgMember) MinimumCycleDuration added in v0.18.0 

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

func (*OrgMember) OnError added in v0.18.0 

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

func (*OrgMember) OnSuccess added in v0.107.0 

func (o *OrgMember) OnSuccess() error

func (*OrgMember) QueryLimit added in v0.64.4 

func (h *OrgMember) QueryLimit() uint64

func (*OrgMember) Reduce added in v0.33.5 

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

func (*OrgMember) Subscription added in v1.19.3 

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

func (*OrgMember) ViewModel added in v0.18.0 

func (m *OrgMember) 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 (_ *PasswordAgePolicy) AggregateTypes() []es_models.AggregateType

func (*PasswordAgePolicy) CurrentSequence added in v0.109.13 

func (o *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 (m *PasswordAgePolicy) OnError(event *es_models.Event, err error) error

func (*PasswordAgePolicy) OnSuccess added in v0.107.0 

func (m *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 (m *PasswordAgePolicy) Reduce(event *es_models.Event) (err error)

func (*PasswordAgePolicy) Subscription added in v1.19.3 

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

func (*PasswordAgePolicy) ViewModel added in v0.92.0 

func (m *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 (_ *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) Subscription added in v1.19.3 

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

func (*PasswordComplexityPolicy) ViewModel added in v0.92.0 

func (p *PasswordComplexityPolicy) ViewModel() string

type PrivacyPolicy added in v1.18.0 

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

func (*PrivacyPolicy) AggregateTypes added in v1.18.0 

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

func (*PrivacyPolicy) CurrentSequence added in v1.18.0 

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

func (*PrivacyPolicy) EventQuery added in v1.18.0 

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

func (*PrivacyPolicy) Eventstore added in v1.18.0 

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

func (*PrivacyPolicy) LockDuration added in v1.18.0 

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

func (*PrivacyPolicy) MinimumCycleDuration added in v1.18.0 

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

func (*PrivacyPolicy) OnError added in v1.18.0 

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

func (*PrivacyPolicy) OnSuccess added in v1.18.0 

func (p *PrivacyPolicy) OnSuccess() error

func (*PrivacyPolicy) QueryLimit added in v1.18.0 

func (h *PrivacyPolicy) QueryLimit() uint64

func (*PrivacyPolicy) Reduce added in v1.18.0 

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

func (*PrivacyPolicy) Subscription added in v1.19.3 

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

func (*PrivacyPolicy) ViewModel added in v1.18.0 

func (p *PrivacyPolicy) ViewModel() string

type Project added in v0.25.0 

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

func (*Project) AggregateTypes added in v0.109.13 

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

func (*Project) CurrentSequence added in v0.109.13 

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

func (*Project) EventQuery added in v0.25.0 

func (p *Project) EventQuery() (*models.SearchQuery, error)

func (*Project) Eventstore added in v0.109.13 

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

func (*Project) LockDuration added in v0.109.18 

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

func (*Project) MinimumCycleDuration added in v0.25.0 

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

func (*Project) OnError added in v0.25.0 

func (p *Project) OnError(event *models.Event, err error) error

func (*Project) OnSuccess added in v0.107.0 

func (p *Project) OnSuccess() error

func (*Project) QueryLimit added in v0.64.4 

func (h *Project) QueryLimit() uint64

func (*Project) Reduce added in v0.33.5 

func (p *Project) Reduce(event *models.Event) (err error)

func (*Project) Subscription added in v1.19.3 

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

func (*Project) ViewModel added in v0.25.0 

func (p *Project) ViewModel() string

type ProjectGrant added in v0.25.0 

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

func (*ProjectGrant) AggregateTypes added in v0.109.13 

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

func (*ProjectGrant) CurrentSequence added in v0.109.13 

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

func (*ProjectGrant) EventQuery added in v0.25.0 

func (p *ProjectGrant) EventQuery() (*models.SearchQuery, error)

func (*ProjectGrant) Eventstore added in v0.109.13 

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

func (*ProjectGrant) LockDuration added in v0.109.18 

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

func (*ProjectGrant) MinimumCycleDuration added in v0.25.0 

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

func (*ProjectGrant) OnError added in v0.25.0 

func (p *ProjectGrant) OnError(event *models.Event, err error) error

func (*ProjectGrant) OnSuccess added in v0.107.0 

func (p *ProjectGrant) OnSuccess() error

func (*ProjectGrant) QueryLimit added in v0.64.4 

func (h *ProjectGrant) QueryLimit() uint64

func (*ProjectGrant) Reduce added in v0.33.5 

func (p *ProjectGrant) Reduce(event *models.Event) (err error)

func (*ProjectGrant) Subscription added in v1.19.3 

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

func (*ProjectGrant) ViewModel added in v0.25.0 

func (p *ProjectGrant) ViewModel() string

type ProjectGrantMember 

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

func (*ProjectGrantMember) AggregateTypes added in v0.109.13 

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

func (*ProjectGrantMember) CurrentSequence added in v0.109.13 

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

func (*ProjectGrantMember) EventQuery 

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

func (*ProjectGrantMember) Eventstore added in v0.109.13 

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

func (*ProjectGrantMember) LockDuration added in v0.109.18 

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

func (*ProjectGrantMember) MinimumCycleDuration 

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

func (*ProjectGrantMember) OnError 

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

func (*ProjectGrantMember) OnSuccess added in v0.107.0 

func (p *ProjectGrantMember) OnSuccess() error

func (*ProjectGrantMember) QueryLimit added in v0.64.4 

func (h *ProjectGrantMember) QueryLimit() uint64

func (*ProjectGrantMember) Reduce added in v0.33.5 

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

func (*ProjectGrantMember) Subscription added in v1.19.3 

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

func (*ProjectGrantMember) ViewModel 

func (p *ProjectGrantMember) ViewModel() string

type ProjectMember 

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

func (*ProjectMember) AggregateTypes added in v0.109.13 

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

func (*ProjectMember) CurrentSequence added in v0.109.13 

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

func (*ProjectMember) EventQuery 

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

func (*ProjectMember) Eventstore added in v0.109.13 

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

func (*ProjectMember) LockDuration added in v0.109.18 

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

func (*ProjectMember) MinimumCycleDuration 

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

func (*ProjectMember) OnError 

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

func (*ProjectMember) OnSuccess added in v0.107.0 

func (p *ProjectMember) OnSuccess() error

func (*ProjectMember) QueryLimit added in v0.64.4 

func (h *ProjectMember) QueryLimit() uint64

func (*ProjectMember) Reduce added in v0.33.5 

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

func (*ProjectMember) Subscription added in v1.19.3 

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

func (*ProjectMember) ViewModel 

func (p *ProjectMember) ViewModel() string

type ProjectRole 

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

func (*ProjectRole) AggregateTypes added in v0.109.13 

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

func (*ProjectRole) CurrentSequence added in v0.109.13 

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

func (*ProjectRole) EventQuery 

func (p *ProjectRole) EventQuery() (*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 

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

func (*ProjectRole) OnError 

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

func (*ProjectRole) OnSuccess added in v0.107.0 

func (p *ProjectRole) OnSuccess() error

func (*ProjectRole) QueryLimit added in v0.64.4 

func (h *ProjectRole) QueryLimit() uint64

func (*ProjectRole) Reduce added in v0.33.5 

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

func (*ProjectRole) Subscription added in v1.19.3 

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

func (*ProjectRole) ViewModel 

func (p *ProjectRole) ViewModel() string

type User added in v0.12.0 

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

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

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

func (*User) OnError added in v0.12.0 

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

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

func (*User) ProcessUser added in v0.28.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 added in v0.12.0 

func (u *User) ViewModel() string

type UserGrant added in v0.12.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.12.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.12.0 

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

func (*UserGrant) OnError added in v0.12.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.12.0 

func (u *UserGrant) ViewModel() string

type UserMembership added in v0.66.0 

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 (u *UserMembership) CurrentSequence() (uint64, error)

func (*UserMembership) EventQuery added in v0.66.0 

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

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

func (*UserMembership) OnError added in v0.66.0 

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

func (h *UserMembership) QueryLimit() uint64

func (*UserMembership) Reduce added in v0.66.0 

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

func (m *UserMembership) 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.