domain

Documentation

Index

• func SetupCommandHandlerDomain(ctx context.Context, esClient esApi.EventStoreClient) error
• type GatewayDomain
  • func NewGatewayDomain(ctx context.Context, eventBus eventsourcing.EventBusConsumer, ...) (*GatewayDomain, error)
• type QueryHandlerDomain
  • func NewQueryHandlerDomain(ctx context.Context, eventBus eventsourcing.EventBusConsumer, ...) (*QueryHandlerDomain, error)

Functions

func SetupCommandHandlerDomain

func SetupCommandHandlerDomain(ctx context.Context, esClient esApi.EventStoreClient) error

SetupCommandHandlerDomain sets up the necessary handlers/repositories for the command side of es/cqrs.

Types

type GatewayDomain

type GatewayDomain struct {
	UserRoleBindingRepository      repositories.UserRoleBindingRepository
	UserRepository                 repositories.UserRepository
	TenantRepository               repositories.TenantRepository
	TenantUserRepository           repositories.TenantUserRepository
	ClusterRepository              repositories.ClusterRepository
	TenantClusterBindingRepository repositories.TenantClusterBindingRepository
	ClusterAccessRepo              repositories.ClusterAccessRepository
}

func NewGatewayDomain

func NewGatewayDomain(ctx context.Context, eventBus eventsourcing.EventBusConsumer, esClient eventsourcingApi.EventStoreClient) (*GatewayDomain, error)

type QueryHandlerDomain

type QueryHandlerDomain struct {
	UserRoleBindingRepository      repositories.UserRoleBindingRepository
	UserRepository                 repositories.UserRepository
	TenantRepository               repositories.TenantRepository
	TenantUserRepository           repositories.TenantUserRepository
	ClusterRepository              repositories.ClusterRepository
	TenantClusterBindingRepository repositories.TenantClusterBindingRepository
	ClusterAccessRepo              repositories.ClusterAccessRepository
}

func NewQueryHandlerDomain

func NewQueryHandlerDomain(ctx context.Context, eventBus eventsourcing.EventBusConsumer, esClient eventsourcingApi.EventStoreClient) (*QueryHandlerDomain, error)