query

package
v1.43.2 Latest Latest
Warning

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

 Go to latest Published: Sep 30, 2021 License: Apache-2.0 Imports: 25 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	ActionColumnID = Column{
					// contains filtered or unexported fields
	}
	ActionColumnCreationDate = Column{
								// contains filtered or unexported fields
	}
	ActionColumnChangeDate = Column{
							// contains filtered or unexported fields
	}
	ActionColumnResourceOwner = Column{
								// contains filtered or unexported fields
	}
	ActionColumnSequence = Column{
							// contains filtered or unexported fields
	}
	ActionColumnState = Column{
						// contains filtered or unexported fields
	}
	ActionColumnName = Column{
						// contains filtered or unexported fields
	}
	ActionColumnScript = Column{
						// contains filtered or unexported fields
	}
	ActionColumnTimeout = Column{
						// contains filtered or unexported fields
	}
	ActionColumnAllowedToFail = Column{
								// contains filtered or unexported fields
	}
)
View Source 
var (
	FlowsTriggersColumnFlowType = Column{
								// contains filtered or unexported fields
	}
	FlowsTriggersColumnTriggerType = Column{
									// contains filtered or unexported fields
	}
	FlowsTriggersColumnResourceOwner = Column{
										// contains filtered or unexported fields
	}
	FlowsTriggersColumnTriggerSequence = Column{
										// contains filtered or unexported fields
	}
	FlowsTriggersColumnActionID = Column{
								// contains filtered or unexported fields
	}
)
View Source 
var (
	CurrentSequenceColAggregateType = Column{
									// contains filtered or unexported fields
	}
	CurrentSequenceColCurrentSequence = Column{
										// contains filtered or unexported fields
	}
	CurrentSequenceColTimestamp = Column{
								// contains filtered or unexported fields
	}
	CurrentSequenceColProjectionName = Column{
										// contains filtered or unexported fields
	}
)
View Source 
var (
	OrgColumnID = Column{
				// contains filtered or unexported fields
	}
	OrgColumnCreationDate = Column{
							// contains filtered or unexported fields
	}
	OrgColumnChangeDate = Column{
						// contains filtered or unexported fields
	}
	OrgColumnResourceOwner = Column{
							// contains filtered or unexported fields
	}
	OrgColumnState = Column{
					// contains filtered or unexported fields
	}
	OrgColumnSequence = Column{
						// contains filtered or unexported fields
	}
	OrgColumnName = Column{
					// contains filtered or unexported fields
	}
	OrgColumnDomain = Column{
					// contains filtered or unexported fields
	}
)
View Source 
var (
	ErrInvalidCompare = errors.New("invalid compare")
	ErrMissingColumn  = errors.New("missing column")
	ErrInvalidNumber  = errors.New("value is no number")
)

Functions

func NewUserEventSearchQuery 

func NewUserEventSearchQuery(userID, orgID string, sequence uint64) *eventstore.SearchQueryBuilder

Types

type Action added in v1.42.0 

type Action struct {
	ID            string
	CreationDate  time.Time
	ChangeDate    time.Time
	ResourceOwner string
	State         domain.ActionState
	Sequence      uint64

	Name          string
	Script        string
	Timeout       time.Duration
	AllowedToFail bool
}

type ActionSearchQueries added in v1.42.0 

type ActionSearchQueries struct {
	SearchRequest
	Queries []SearchQuery
}

func (*ActionSearchQueries) ToQuery added in v1.42.0 

func (q *ActionSearchQueries) ToQuery(query sq.SelectBuilder) sq.SelectBuilder

type Actions added in v1.43.0 

type Actions struct {
	SearchResponse
	Actions []*Action
}

type Column added in v1.43.0 

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

type Config 

type Config struct {
	Eventstore types.SQLUser
}

type Flow added in v1.42.0 

type Flow struct {
	ID            string
	CreationDate  time.Time
	ChangeDate    time.Time
	ResourceOwner string
	Sequence      uint64
	Type          domain.FlowType

	TriggerActions map[domain.TriggerType][]*Action
}

type IAMIDPConfigReadModel 

type IAMIDPConfigReadModel struct {
	IDPConfigReadModel
	// contains filtered or unexported fields
}

func NewIAMIDPConfigReadModel 

func NewIAMIDPConfigReadModel(iamID, configID string) *IAMIDPConfigReadModel

func (*IAMIDPConfigReadModel) AppendEvents 

func (rm *IAMIDPConfigReadModel) AppendEvents(events ...eventstore.EventReader)

func (*IAMIDPConfigReadModel) Query 

func (rm *IAMIDPConfigReadModel) Query() *eventstore.SearchQueryBuilder

type IAMIDPConfigsReadModel 

type IAMIDPConfigsReadModel struct {
	IDPConfigsReadModel
}

func (*IAMIDPConfigsReadModel) AppendEvents 

func (rm *IAMIDPConfigsReadModel) AppendEvents(events ...eventstore.EventReader)

type IAMLabelPolicyReadModel 

type IAMLabelPolicyReadModel struct{ LabelPolicyReadModel }

func (*IAMLabelPolicyReadModel) AppendEvents 

func (rm *IAMLabelPolicyReadModel) AppendEvents(events ...eventstore.EventReader)

type IAMLockoutPolicyReadModel added in v1.29.0 

type IAMLockoutPolicyReadModel struct {
	LockoutPolicyReadModel
}

func (*IAMLockoutPolicyReadModel) AppendEvents added in v1.29.0 

func (rm *IAMLockoutPolicyReadModel) AppendEvents(events ...eventstore.EventReader)

type IAMLoginPolicyReadModel 

type IAMLoginPolicyReadModel struct{ LoginPolicyReadModel }

func (*IAMLoginPolicyReadModel) AppendEvents 

func (rm *IAMLoginPolicyReadModel) AppendEvents(events ...eventstore.EventReader)

type IAMMemberReadModel 

type IAMMemberReadModel struct {
	MemberReadModel
	// contains filtered or unexported fields
}

func NewIAMMemberReadModel 

func NewIAMMemberReadModel(iamID, userID string) *IAMMemberReadModel

func (*IAMMemberReadModel) AppendEvents 

func (rm *IAMMemberReadModel) AppendEvents(events ...eventstore.EventReader)

func (*IAMMemberReadModel) Query 

func (rm *IAMMemberReadModel) Query() *eventstore.SearchQueryBuilder

type IAMMembersReadModel 

type IAMMembersReadModel struct {
	MembersReadModel
}

func (*IAMMembersReadModel) AppendEvents 

func (rm *IAMMembersReadModel) AppendEvents(events ...eventstore.EventReader)

type IAMOrgIAMPolicyReadModel 

type IAMOrgIAMPolicyReadModel struct{ OrgIAMPolicyReadModel }

func (*IAMOrgIAMPolicyReadModel) AppendEvents 

func (rm *IAMOrgIAMPolicyReadModel) AppendEvents(events ...eventstore.EventReader)

type IAMPasswordAgePolicyReadModel 

type IAMPasswordAgePolicyReadModel struct {
	PasswordAgePolicyReadModel
}

func (*IAMPasswordAgePolicyReadModel) AppendEvents 

func (rm *IAMPasswordAgePolicyReadModel) AppendEvents(events ...eventstore.EventReader)

type IAMPasswordComplexityPolicyReadModel 

type IAMPasswordComplexityPolicyReadModel struct {
	PasswordComplexityPolicyReadModel
}

func (*IAMPasswordComplexityPolicyReadModel) AppendEvents 

func (rm *IAMPasswordComplexityPolicyReadModel) AppendEvents(events ...eventstore.EventReader)

type IDPConfigReadModel 

type IDPConfigReadModel struct {
	eventstore.ReadModel

	State        domain.IDPConfigState
	ConfigID     string
	Name         string
	AutoRegister bool
	StylingType  domain.IDPConfigStylingType
	ProviderType domain.IdentityProviderType

	OIDCConfig *OIDCConfigReadModel
	JWTConfig  *JWTConfigReadModel
}

func NewIDPConfigReadModel 

func NewIDPConfigReadModel(configID string) *IDPConfigReadModel

func (*IDPConfigReadModel) AppendEvents 

func (rm *IDPConfigReadModel) AppendEvents(events ...eventstore.EventReader)

func (*IDPConfigReadModel) Reduce 

func (rm *IDPConfigReadModel) Reduce() error

type IDPConfigsReadModel 

type IDPConfigsReadModel struct {
	eventstore.ReadModel

	Configs []*IDPConfigReadModel
}

func (*IDPConfigsReadModel) AppendEvents 

func (rm *IDPConfigsReadModel) AppendEvents(events ...eventstore.EventReader)

func (*IDPConfigsReadModel) ConfigByID 

func (rm *IDPConfigsReadModel) ConfigByID(id string) (idx int, config *IDPConfigReadModel)

func (*IDPConfigsReadModel) Reduce 

func (rm *IDPConfigsReadModel) Reduce() error

type JWTConfigReadModel added in v1.39.0 

type JWTConfigReadModel struct {
	eventstore.ReadModel

	IDPConfigID  string
	JWTEndpoint  string
	Issuer       string
	KeysEndpoint string
}

func (*JWTConfigReadModel) Reduce added in v1.39.0 

func (rm *JWTConfigReadModel) Reduce() error

type LabelPolicyReadModel 

type LabelPolicyReadModel struct {
	eventstore.ReadModel

	PrimaryColor        string
	BackgroundColor     string
	WarnColor           string
	FontColor           string
	PrimaryColorDark    string
	BackgroundColorDark string
	WarnColorDark       string
	FontColorDark       string
	IsActive            bool
}

func (*LabelPolicyReadModel) Reduce 

func (rm *LabelPolicyReadModel) Reduce() error

type LatestSequence added in v1.43.0 

type LatestSequence struct {
	Sequence  uint64
	Timestamp time.Time
}

type LockoutPolicyReadModel added in v1.29.0 

type LockoutPolicyReadModel struct {
	eventstore.ReadModel

	MaxAttempts         uint64
	ShowLockOutFailures bool
}

func (*LockoutPolicyReadModel) Reduce added in v1.29.0 

func (rm *LockoutPolicyReadModel) Reduce() error

type LoginPolicyReadModel 

type LoginPolicyReadModel struct {
	eventstore.ReadModel

	AllowUserNamePassword bool
	AllowRegister         bool
	AllowExternalIDP      bool
	ForceMFA              bool
	PasswordlessType      domain.PasswordlessType
	IsActive              bool
}

func (*LoginPolicyReadModel) Reduce 

func (rm *LoginPolicyReadModel) Reduce() error

type MemberReadModel 

type MemberReadModel struct {
	eventstore.ReadModel

	UserID string
	Roles  []string
}

MemberReadModel represenets the default member view. It's computed from events.

func NewMemberReadModel 

func NewMemberReadModel(userID string) *MemberReadModel

NewMemberReadModel is the default constructor of MemberReadModel

func (*MemberReadModel) Reduce 

func (rm *MemberReadModel) Reduce() error

Reduce extends eventstore.MemberReadModel

type MembersReadModel 

type MembersReadModel struct {
	eventstore.ReadModel

	Members []*MemberReadModel
}

func (*MembersReadModel) AppendEvents 

func (rm *MembersReadModel) AppendEvents(events ...eventstore.EventReader)

func (*MembersReadModel) MemberByUserID 

func (rm *MembersReadModel) MemberByUserID(id string) (idx int, member *MemberReadModel)

func (*MembersReadModel) Reduce 

func (rm *MembersReadModel) Reduce() (err error)

type NumberComparison added in v1.43.0 

type NumberComparison int
const (
	NumberEquals NumberComparison = iota
	NumberNotEquals
	NumberLess
	NumberGreater
	NumberListContains
)

func NumberComparisonFromMethod deprecated added in v1.43.0 

func NumberComparisonFromMethod(m domain.SearchMethod) NumberComparison

Deprecated: Use NumberComparison, will be removed as soon as all calls are changed to query

type NumberQuery added in v1.43.0 

type NumberQuery struct {
	Column  Column
	Number  interface{}
	Compare NumberComparison
}

func NewNumberQuery added in v1.43.0 

func NewNumberQuery(c Column, value interface{}, compare NumberComparison) (*NumberQuery, error)

func (*NumberQuery) ToQuery added in v1.43.0 

func (q *NumberQuery) ToQuery(query sq.SelectBuilder) sq.SelectBuilder

type OIDCConfigReadModel 

type OIDCConfigReadModel struct {
	eventstore.ReadModel

	IDPConfigID           string
	ClientID              string
	ClientSecret          *crypto.CryptoValue
	Issuer                string
	AuthorizationEndpoint string
	TokenEndpoint         string
	Scopes                []string
	IDPDisplayNameMapping domain.OIDCMappingField
	UserNameMapping       domain.OIDCMappingField
}

func (*OIDCConfigReadModel) Reduce 

func (rm *OIDCConfigReadModel) Reduce() error

type Org added in v1.43.0 

type Org struct {
	ID            string
	CreationDate  time.Time
	ChangeDate    time.Time
	ResourceOwner string
	State         domain.OrgState
	Sequence      uint64

	Name   string
	Domain string
}

type OrgIAMPolicyReadModel 

type OrgIAMPolicyReadModel struct {
	eventstore.ReadModel

	UserLoginMustBeDomain bool
}

func (*OrgIAMPolicyReadModel) Reduce 

func (rm *OrgIAMPolicyReadModel) Reduce() error

type OrgLabelPolicyReadModel 

type OrgLabelPolicyReadModel struct{ LabelPolicyReadModel }

func (*OrgLabelPolicyReadModel) AppendEvents 

func (rm *OrgLabelPolicyReadModel) AppendEvents(events ...eventstore.EventReader)

type OrgLoginPolicyReadModel 

type OrgLoginPolicyReadModel struct{ LoginPolicyReadModel }

func (*OrgLoginPolicyReadModel) AppendEvents 

func (rm *OrgLoginPolicyReadModel) AppendEvents(events ...eventstore.EventReader)

type OrgMemberReadModel 

type OrgMemberReadModel MemberReadModel

func (*OrgMemberReadModel) AppendEvents 

func (rm *OrgMemberReadModel) AppendEvents(events ...eventstore.EventReader)

type OrgMembersReadModel 

type OrgMembersReadModel struct {
	MembersReadModel
}

func (*OrgMembersReadModel) AppendEvents 

func (rm *OrgMembersReadModel) AppendEvents(events ...eventstore.EventReader)

type OrgOrgIAMPolicyReadModel 

type OrgOrgIAMPolicyReadModel struct{ OrgIAMPolicyReadModel }

func (*OrgOrgIAMPolicyReadModel) AppendEvents 

func (rm *OrgOrgIAMPolicyReadModel) AppendEvents(events ...eventstore.EventReader)

type OrgPasswordAgePolicyReadModel 

type OrgPasswordAgePolicyReadModel struct {
	PasswordAgePolicyReadModel
}

func (*OrgPasswordAgePolicyReadModel) AppendEvents 

func (rm *OrgPasswordAgePolicyReadModel) AppendEvents(events ...eventstore.EventReader)

type OrgPasswordComplexityPolicyReadModel 

type OrgPasswordComplexityPolicyReadModel struct {
	PasswordComplexityPolicyReadModel
}

func (*OrgPasswordComplexityPolicyReadModel) AppendEvents 

func (rm *OrgPasswordComplexityPolicyReadModel) AppendEvents(events ...eventstore.EventReader)

type OrgPasswordLockoutPolicyReadModel 

type OrgPasswordLockoutPolicyReadModel struct {
	LockoutPolicyReadModel
}

func (*OrgPasswordLockoutPolicyReadModel) AppendEvents 

func (rm *OrgPasswordLockoutPolicyReadModel) AppendEvents(events ...eventstore.EventReader)

type OrgSearchQueries added in v1.43.0 

type OrgSearchQueries struct {
	SearchRequest
	Queries []SearchQuery
}

type Orgs added in v1.43.0 

type Orgs struct {
	SearchResponse
	Orgs []*Org
}

type PasswordAgePolicyReadModel 

type PasswordAgePolicyReadModel struct {
	eventstore.ReadModel

	ExpireWarnDays uint64
	MaxAgeDays     uint64
}

func (*PasswordAgePolicyReadModel) Reduce 

func (rm *PasswordAgePolicyReadModel) Reduce() error

type PasswordComplexityPolicyReadModel 

type PasswordComplexityPolicyReadModel struct {
	eventstore.ReadModel

	MinLength    uint64
	HasLowercase bool
	HasUpperCase bool
	HasNumber    bool
	HasSymbol    bool
}

func (*PasswordComplexityPolicyReadModel) Reduce 

func (rm *PasswordComplexityPolicyReadModel) Reduce() error

type Queries 

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

func StartQueries 

func StartQueries(ctx context.Context, es *eventstore.Eventstore, projections projection.Config, defaults sd.SystemDefaults) (repo *Queries, err error)

func (*Queries) DefaultIDPConfigByID 

func (r *Queries) DefaultIDPConfigByID(ctx context.Context, idpConfigID string) (*domain.IDPConfigView, error)

func (*Queries) ExistsOrg added in v1.43.0 

func (q *Queries) ExistsOrg(ctx context.Context, id string) (err error)

func (*Queries) GetActionByID added in v1.43.0 

func (q *Queries) GetActionByID(ctx context.Context, id string, orgID string) (*Action, error)

func (*Queries) GetActionsByFlowAndTriggerType added in v1.42.0 

func (q *Queries) GetActionsByFlowAndTriggerType(ctx context.Context, flowType domain.FlowType, triggerType domain.TriggerType, orgID string) ([]*Action, error)

func (*Queries) GetFlow added in v1.42.0 

func (q *Queries) GetFlow(ctx context.Context, flowType domain.FlowType, orgID string) (*Flow, error)

func (*Queries) GetFlowTypesOfActionID added in v1.42.0 

func (q *Queries) GetFlowTypesOfActionID(ctx context.Context, actionID string) ([]domain.FlowType, error)

func (*Queries) IAMByID 

func (r *Queries) IAMByID(ctx context.Context, id string) (_ *iam_model.IAM, err error)

func (*Queries) IAMMemberByID 

func (r *Queries) IAMMemberByID(ctx context.Context, iamID, userID string) (member *IAMMemberReadModel, err error)

func (*Queries) IsOrgUnique added in v1.43.0 

func (q *Queries) IsOrgUnique(ctx context.Context, name, domain string) (isUnique bool, err error)

func (*Queries) OrgByDomainGlobal added in v1.43.0 

func (q *Queries) OrgByDomainGlobal(ctx context.Context, domain string) (*Org, error)

func (*Queries) OrgByID added in v1.43.0 

func (q *Queries) OrgByID(ctx context.Context, id string) (*Org, error)

func (*Queries) SearchActions added in v1.42.0 

func (q *Queries) SearchActions(ctx context.Context, queries *ActionSearchQueries) (actions *Actions, err error)

func (*Queries) SearchOrgs added in v1.43.0 

func (q *Queries) SearchOrgs(ctx context.Context, queries *OrgSearchQueries) (orgs *Orgs, err error)

func (*Queries) UserEvents 

func (q *Queries) UserEvents(ctx context.Context, orgID, userID string, sequence uint64) ([]eventstore.EventReader, error)

type ReadModel 

type ReadModel struct {
	eventstore.ReadModel

	SetUpStarted domain.Step
	SetUpDone    domain.Step

	Members IAMMembersReadModel
	IDPs    IAMIDPConfigsReadModel

	GlobalOrgID string
	ProjectID   string

	DefaultLoginPolicy              IAMLoginPolicyReadModel
	DefaultLabelPolicy              IAMLabelPolicyReadModel
	DefaultOrgIAMPolicy             IAMOrgIAMPolicyReadModel
	DefaultPasswordComplexityPolicy IAMPasswordComplexityPolicyReadModel
	DefaultPasswordAgePolicy        IAMPasswordAgePolicyReadModel
	DefaultPasswordLockoutPolicy    IAMLockoutPolicyReadModel
}

func NewReadModel 

func NewReadModel(id string) *ReadModel

func (*ReadModel) AppendAndReduce 

func (rm *ReadModel) AppendAndReduce(events ...eventstore.EventReader) error

func (*ReadModel) AppendEvents 

func (rm *ReadModel) AppendEvents(events ...eventstore.EventReader)

func (*ReadModel) IDPByID 

func (rm *ReadModel) IDPByID(idpID string) *IAMIDPConfigReadModel

func (*ReadModel) Query 

func (rm *ReadModel) Query() *eventstore.SearchQueryBuilder

func (*ReadModel) Reduce 

func (rm *ReadModel) Reduce() (err error)

type SearchQuery added in v1.42.0 

type SearchQuery interface {
	ToQuery(sq.SelectBuilder) sq.SelectBuilder
}

func NewActionNameSearchQuery added in v1.42.0 

func NewActionNameSearchQuery(method TextComparison, value string) (SearchQuery, error)

func NewActionResourceOwnerQuery added in v1.42.0 

func NewActionResourceOwnerQuery(id string) (SearchQuery, error)

func NewActionStateSearchQuery added in v1.42.0 

func NewActionStateSearchQuery(value domain.ActionState) (SearchQuery, error)

func NewOrgDomainSearchQuery added in v1.43.0 

func NewOrgDomainSearchQuery(method TextComparison, value string) (SearchQuery, error)

func NewOrgNameSearchQuery added in v1.43.0 

func NewOrgNameSearchQuery(method TextComparison, value string) (SearchQuery, error)

type SearchRequest added in v1.42.0 

type SearchRequest struct {
	Offset        uint64
	Limit         uint64
	SortingColumn Column
	Asc           bool
}

type SearchResponse added in v1.43.0 

type SearchResponse struct {
	Count uint64
	*LatestSequence
}

type TextComparison added in v1.42.0 

type TextComparison int
const (
	TextEquals TextComparison = iota
	TextEqualsIgnoreCase
	TextStartsWith
	TextStartsWithIgnoreCase
	TextEndsWith
	TextEndsWithIgnoreCase
	TextContains
	TextContainsIgnoreCase
	TextListContains
)

func TextComparisonFromMethod deprecated added in v1.43.0 

func TextComparisonFromMethod(m domain.SearchMethod) TextComparison

Deprecated: Use TextComparison, will be removed as soon as all calls are changed to query

type TextQuery added in v1.42.0 

type TextQuery struct {
	Column  Column
	Text    string
	Compare TextComparison
}

func NewTextQuery added in v1.42.0 

func NewTextQuery(col Column, value string, compare TextComparison) (*TextQuery, error)

func (*TextQuery) ToQuery added in v1.42.0 

func (q *TextQuery) ToQuery(query sq.SelectBuilder) sq.SelectBuilder

type UserReadModel 

type UserReadModel struct {
	eventstore.ReadModel
}

func NewUserReadModel 

func NewUserReadModel(id string) *UserReadModel

func (*UserReadModel) AppendAndReduce 

func (rm *UserReadModel) AppendAndReduce(events ...eventstore.EventReader) error

func (*UserReadModel) AppendEvents 

func (rm *UserReadModel) AppendEvents(events ...eventstore.EventReader)

func (*UserReadModel) Query 

func (rm *UserReadModel) Query() *eventstore.SearchQueryBuilder

func (*UserReadModel) Reduce 

func (rm *UserReadModel) Reduce() (err error)

Source Files

View all Source files

Directories

Path Synopsis
flow
org/owner

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.