aggregates

Documentation

Index

• func NewCertificateAggregate(aggregateManager es.AggregateStore) es.Aggregate
• func NewClusterAggregate(aggregateManager es.AggregateStore) es.Aggregate
• func NewTenantAggregate(aggregateManager es.AggregateStore) es.Aggregate
• func NewTenantClusterBindingAggregate(aggregateManager es.AggregateStore) es.Aggregate
• func NewUserAggregate(aggregateManager es.AggregateStore) es.Aggregate
• func NewUserRoleBindingAggregate(aggregateManager es.AggregateStore) es.Aggregate
• type CertificateAggregate
  • func (a *CertificateAggregate) ApplyEvent(event es.Event) error
  • func (a *CertificateAggregate) HandleCommand(ctx context.Context, cmd es.Command) (*es.CommandReply, error)
• type ClusterAggregate
  • func (a *ClusterAggregate) ApplyEvent(event es.Event) error
  • func (a *ClusterAggregate) HandleCommand(ctx context.Context, cmd es.Command) (*es.CommandReply, error)
• type DomainAggregateBase
  • func (a *DomainAggregateBase) Authorize(ctx context.Context, cmd es.Command, expectedResource uuid.UUID) error
  • func (a *DomainAggregateBase) DefaultReply() *es.CommandReply
  • func (a *DomainAggregateBase) Validate(ctx context.Context, cmd es.Command) error
• type TenantAggregate
  • func (a *TenantAggregate) ApplyEvent(event es.Event) error
  • func (a *TenantAggregate) HandleCommand(ctx context.Context, cmd es.Command) (*es.CommandReply, error)
• type TenantClusterBindingAggregate
  • func (a *TenantClusterBindingAggregate) ApplyEvent(event es.Event) error
  • func (a *TenantClusterBindingAggregate) HandleCommand(ctx context.Context, cmd es.Command) (*es.CommandReply, error)
• type UserAggregate
  • func (a *UserAggregate) ApplyEvent(event es.Event) error
  • func (a *UserAggregate) HandleCommand(ctx context.Context, cmd es.Command) (*es.CommandReply, error)
• type UserRoleBindingAggregate
  • func (a *UserRoleBindingAggregate) ApplyEvent(event es.Event) error
  • func (a *UserRoleBindingAggregate) HandleCommand(ctx context.Context, cmd es.Command) (*es.CommandReply, error)

Functions

func NewCertificateAggregate

func NewCertificateAggregate(aggregateManager es.AggregateStore) es.Aggregate

CertificateAggregate creates a new CertificateAggregate

func NewClusterAggregate

func NewClusterAggregate(aggregateManager es.AggregateStore) es.Aggregate

ClusterAggregate creates a new ClusterAggregate

func NewTenantAggregate

func NewTenantAggregate(aggregateManager es.AggregateStore) es.Aggregate

NewTenantAggregate creates a new TenantAggregate

func NewTenantClusterBindingAggregate

func NewTenantClusterBindingAggregate(aggregateManager es.AggregateStore) es.Aggregate

NewTenantClusterBindingAggregate creates a new TenantClusterBindingAggregate

func NewUserAggregate

func NewUserAggregate(aggregateManager es.AggregateStore) es.Aggregate

NewUserAggregate creates a new UserAggregate

func NewUserRoleBindingAggregate

func NewUserRoleBindingAggregate(aggregateManager es.AggregateStore) es.Aggregate

NewUserRoleBindingAggregate creates a new UserRoleBindingAggregate

Types

type CertificateAggregate

type CertificateAggregate struct {
	*DomainAggregateBase
	// contains filtered or unexported fields
}

CertificateAggregate is an aggregate for certificates.

func (*CertificateAggregate) ApplyEvent

func (a *CertificateAggregate) ApplyEvent(event es.Event) error

ApplyEvent implements the ApplyEvent method of the Aggregate interface.

func (*CertificateAggregate) HandleCommand

func (a *CertificateAggregate) HandleCommand(ctx context.Context, cmd es.Command) (*es.CommandReply, error)

HandleCommand implements the HandleCommand method of the Aggregate interface.

type ClusterAggregate

type ClusterAggregate struct {
	*DomainAggregateBase
	// contains filtered or unexported fields
}

ClusterAggregate is an aggregate for K8s Clusters.

func (*ClusterAggregate) ApplyEvent

func (a *ClusterAggregate) ApplyEvent(event es.Event) error

ApplyEvent implements the ApplyEvent method of the Aggregate interface.

func (*ClusterAggregate) HandleCommand

func (a *ClusterAggregate) HandleCommand(ctx context.Context, cmd es.Command) (*es.CommandReply, error)

HandleCommand implements the HandleCommand method of the Aggregate interface.

type DomainAggregateBase

type DomainAggregateBase struct {
	*es.BaseAggregate
}

func (*DomainAggregateBase) Authorize

func (a *DomainAggregateBase) Authorize(ctx context.Context, cmd es.Command, expectedResource uuid.UUID) error

Authorization authorizes the command against the issuing users rolebindings

func (*DomainAggregateBase) DefaultReply

func (a *DomainAggregateBase) DefaultReply() *es.CommandReply

DefaultReply creates a default command reply containing the ID and current version of the aggregate.

func (*DomainAggregateBase) Validate

func (a *DomainAggregateBase) Validate(ctx context.Context, cmd es.Command) error

Validate validates if the aggregate exists and is not deleted

type TenantAggregate

type TenantAggregate struct {
	*DomainAggregateBase
	// contains filtered or unexported fields
}

TenantAggregate is an aggregate for Tenants.

func (*TenantAggregate) ApplyEvent

func (a *TenantAggregate) ApplyEvent(event es.Event) error

ApplyEvent implements the ApplyEvent method of the Aggregate interface.

func (*TenantAggregate) HandleCommand

func (a *TenantAggregate) HandleCommand(ctx context.Context, cmd es.Command) (*es.CommandReply, error)

HandleCommand implements the HandleCommand method of the Aggregate interface.

type TenantClusterBindingAggregate

type TenantClusterBindingAggregate struct {
	*DomainAggregateBase
	// contains filtered or unexported fields
}

TenantClusterBindingAggregate is an aggregate for TenantClusterBindings.

func (*TenantClusterBindingAggregate) ApplyEvent

func (a *TenantClusterBindingAggregate) ApplyEvent(event es.Event) error

ApplyEvent implements the ApplyEvent method of the Aggregate interface.

func (*TenantClusterBindingAggregate) HandleCommand

func (a *TenantClusterBindingAggregate) HandleCommand(ctx context.Context, cmd es.Command) (*es.CommandReply, error)

HandleCommand implements the HandleCommand method of the Aggregate interface.

type UserAggregate

type UserAggregate struct {
	*DomainAggregateBase

	Email string
	Name  string
	// contains filtered or unexported fields
}

UserAggregate is an aggregate for Users.

func (*UserAggregate) ApplyEvent

func (a *UserAggregate) ApplyEvent(event es.Event) error

ApplyEvent implements the ApplyEvent method of the Aggregate interface.

func (*UserAggregate) HandleCommand

func (a *UserAggregate) HandleCommand(ctx context.Context, cmd es.Command) (*es.CommandReply, error)

HandleCommand implements the HandleCommand method of the Aggregate interface.

type UserRoleBindingAggregate

type UserRoleBindingAggregate struct {
	*DomainAggregateBase
	// contains filtered or unexported fields
}

UserRoleBindingAggregate is an aggregate for UserRoleBindings.

func (*UserRoleBindingAggregate) ApplyEvent

func (a *UserRoleBindingAggregate) ApplyEvent(event es.Event) error

ApplyEvent implements the ApplyEvent method of the Aggregate interface.

func (*UserRoleBindingAggregate) HandleCommand

func (a *UserRoleBindingAggregate) HandleCommand(ctx context.Context, cmd es.Command) (*es.CommandReply, error)

HandleCommand implements the HandleCommand method of the Aggregate interface.