Documentation ¶
Index ¶
- 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 ClusterAggregate
- type DomainAggregateBase
- type TenantAggregate
- type TenantClusterBindingAggregate
- type UserAggregate
- type UserRoleBindingAggregate
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func NewClusterAggregate ¶
func NewClusterAggregate(aggregateManager es.AggregateStore) es.Aggregate
NewClusterAggregate creates a new ClusterAggregate
func NewTenantAggregate ¶
func NewTenantAggregate(aggregateManager es.AggregateStore) es.Aggregate
NewTenantAggregate creates a new TenantAggregate
func NewTenantClusterBindingAggregate ¶ added in v0.3.0
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 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) DefaultReply ¶ added in v0.3.0
func (a *DomainAggregateBase) DefaultReply() *es.CommandReply
DefaultReply creates a default command reply containing the ID and current version of the aggregate.
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 ¶ added in v0.3.0
type TenantClusterBindingAggregate struct { *DomainAggregateBase // contains filtered or unexported fields }
TenantClusterBindingAggregate is an aggregate for TenantClusterBindings.
func (*TenantClusterBindingAggregate) ApplyEvent ¶ added in v0.3.0
func (a *TenantClusterBindingAggregate) ApplyEvent(event es.Event) error
ApplyEvent implements the ApplyEvent method of the Aggregate interface.
func (*TenantClusterBindingAggregate) HandleCommand ¶ added in v0.3.0
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.