handler

package
v0.104.1 Latest Latest
Warning

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

 Go to latest Published: Nov 17, 2020 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, eventstore eventstore.Eventstore, repos EventstoreRepos, defaults systemdefaults.SystemDefaults) []query.Handler

Types

type Application 

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

func (*Application) EventQuery 

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

func (*Application) MinimumCycleDuration 

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

func (*Application) OnError 

func (a *Application) OnError(event *models.Event, spoolerError error) 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) ViewModel 

func (a *Application) ViewModel() string

type Config 

type Config struct {
	MinimumCycleDuration types.Duration
}

type Configs 

type Configs map[string]*Config

type EventstoreRepos 

type EventstoreRepos struct {
	ProjectEvents *proj_event.ProjectEventstore
	UserEvents    *usr_event.UserEventstore
	OrgEvents     *org_event.OrgEventstore
	IamEvents     *iam_event.IAMEventstore
}

type ExternalIDP added in v0.87.0 

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

func (*ExternalIDP) EventQuery added in v0.87.0 

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

func (*ExternalIDP) MinimumCycleDuration added in v0.87.0 

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

func (*ExternalIDP) OnError added in v0.87.0 

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

func (*ExternalIDP) QueryLimit added in v0.87.0 

func (h *ExternalIDP) QueryLimit() uint64

func (*ExternalIDP) Reduce added in v0.87.0 

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

func (*ExternalIDP) ViewModel added in v0.87.0 

func (m *ExternalIDP) ViewModel() string

type IDPConfig added in v0.77.0 

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

func (*IDPConfig) EventQuery added in v0.77.0 

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

func (*IDPConfig) MinimumCycleDuration added in v0.77.0 

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

func (*IDPConfig) OnError added in v0.77.0 

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

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) EventQuery added in v0.77.0 

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

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 *models.Event, err error) 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 *models.Event) (err error)

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) EventQuery added in v0.96.0 

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

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 *models.Event, err error) 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 *models.Event) (err error)

func (*LabelPolicy) ViewModel added in v0.96.0 

func (m *LabelPolicy) ViewModel() string

type LoginPolicy added in v0.77.0 

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

func (*LoginPolicy) EventQuery added in v0.77.0 

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

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 *models.Event, err error) 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 *models.Event) (err error)

func (*LoginPolicy) ViewModel added in v0.77.0 

func (m *LoginPolicy) ViewModel() string

type MachineKeys added in v0.81.0 

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

func (*MachineKeys) EventQuery added in v0.81.0 

func (d *MachineKeys) EventQuery() (*models.SearchQuery, error)

func (*MachineKeys) MinimumCycleDuration added in v0.81.0 

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

func (*MachineKeys) OnError added in v0.81.0 

func (d *MachineKeys) OnError(event *models.Event, err error) error

func (*MachineKeys) QueryLimit added in v0.81.0 

func (h *MachineKeys) QueryLimit() uint64

func (*MachineKeys) Reduce added in v0.81.0 

func (d *MachineKeys) Reduce(event *models.Event) (err error)

func (*MachineKeys) ViewModel added in v0.81.0 

func (d *MachineKeys) ViewModel() string

type Org added in v0.18.0 

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

func (*Org) EventQuery added in v0.18.0 

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

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) 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) 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) EventQuery added in v0.26.0 

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

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 *models.Event, err error) 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 *models.Event) (err error)

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) EventQuery added in v0.92.0 

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

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 *models.Event, err error) 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 *models.Event) (err error)

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

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

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 *models.Event, err error) 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 *models.Event) (err error)

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) EventQuery added in v0.92.0 

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

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 *models.Event, err error) 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 *models.Event) (err error)

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) EventQuery added in v0.92.0 

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

func (*PasswordComplexityPolicy) MinimumCycleDuration added in v0.92.0 

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

func (*PasswordComplexityPolicy) OnError added in v0.92.0 

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

func (*PasswordComplexityPolicy) QueryLimit added in v0.92.0 

func (h *PasswordComplexityPolicy) QueryLimit() uint64

func (*PasswordComplexityPolicy) Reduce added in v0.92.0 

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

func (*PasswordComplexityPolicy) ViewModel added in v0.92.0 

func (m *PasswordComplexityPolicy) ViewModel() string

type PasswordLockoutPolicy added in v0.92.0 

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

func (*PasswordLockoutPolicy) EventQuery added in v0.92.0 

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

func (*PasswordLockoutPolicy) MinimumCycleDuration added in v0.92.0 

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

func (*PasswordLockoutPolicy) OnError added in v0.92.0 

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

func (*PasswordLockoutPolicy) QueryLimit added in v0.92.0 

func (h *PasswordLockoutPolicy) QueryLimit() uint64

func (*PasswordLockoutPolicy) Reduce added in v0.92.0 

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

func (*PasswordLockoutPolicy) ViewModel added in v0.92.0 

func (m *PasswordLockoutPolicy) ViewModel() string

type Project added in v0.25.0 

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

func (*Project) EventQuery added in v0.25.0 

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

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) 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) 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) EventQuery added in v0.25.0 

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

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) 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) ViewModel added in v0.25.0 

func (p *ProjectGrant) ViewModel() string

type ProjectGrantMember 

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

func (*ProjectGrantMember) EventQuery 

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

func (*ProjectGrantMember) MinimumCycleDuration 

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

func (*ProjectGrantMember) OnError 

func (p *ProjectGrantMember) OnError(event *models.Event, err error) 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 *models.Event) (err error)

func (*ProjectGrantMember) ViewModel 

func (p *ProjectGrantMember) ViewModel() string

type ProjectMember 

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

func (*ProjectMember) EventQuery 

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

func (*ProjectMember) MinimumCycleDuration 

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

func (*ProjectMember) OnError 

func (p *ProjectMember) OnError(event *models.Event, err error) 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 *models.Event) (err error)

func (*ProjectMember) ViewModel 

func (p *ProjectMember) ViewModel() string

type ProjectRole 

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

func (*ProjectRole) EventQuery 

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

func (*ProjectRole) MinimumCycleDuration 

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

func (*ProjectRole) OnError 

func (p *ProjectRole) OnError(event *models.Event, err error) 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) ViewModel 

func (p *ProjectRole) ViewModel() string

type User added in v0.12.0 

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

func (*User) EventQuery added in v0.12.0 

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

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 *models.Event, err error) error

func (*User) ProcessOrg added in v0.28.0 

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

func (*User) ProcessUser added in v0.28.0 

func (u *User) ProcessUser(event *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 *models.Event) (err error)

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

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

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 *models.Event, err error) 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 *models.Event) (err error)

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) EventQuery added in v0.66.0 

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

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 *models.Event, err error) 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 *models.Event) (err error)

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.