handler

package
v1.57.1 Latest Latest
Warning

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

 Go to latest Published: Dec 7, 2021 License: Apache-2.0 Imports: 34 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, command *command.Commands, static static.Storage, localDevMode bool) []query.Handler

Types

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

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

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) Subscription added in v1.19.3 

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

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) Subscription added in v1.19.3 

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

func (*IDPProvider) ViewModel added in v0.77.0 

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

func (*MailTemplate) CurrentSequence added in v0.110.0 

func (m *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 (m *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 Styling added in v1.12.0 

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

func (*Styling) AggregateTypes added in v1.12.0 

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

func (*Styling) CurrentSequence added in v1.12.0 

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

func (*Styling) EventQuery added in v1.12.0 

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

func (*Styling) Eventstore added in v1.12.0 

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

func (*Styling) LockDuration added in v1.12.0 

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

func (*Styling) MinimumCycleDuration added in v1.12.0 

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

func (*Styling) OnError added in v1.12.0 

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

func (*Styling) OnSuccess added in v1.12.0 

func (m *Styling) OnSuccess() error

func (*Styling) QueryLimit added in v1.12.0 

func (h *Styling) QueryLimit() uint64

func (*Styling) Reduce added in v1.12.0 

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

func (*Styling) Subscription added in v1.19.3 

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

func (*Styling) ViewModel added in v1.12.0 

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

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

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.