projection

Documentation

Index

• func Start(ctx context.Context, es *eventstore.Eventstore, config Config) error
• type ActionProjection
  • func NewActionProjection(ctx context.Context, config crdb.StatementHandlerConfig) *ActionProjection
• type Config
• type CustomConfig
• type OrgProjection
  • func NewOrgProjection(ctx context.Context, config crdb.StatementHandlerConfig) *OrgProjection
• type ProjectProjection
  • func NewProjectProjection(ctx context.Context, config crdb.StatementHandlerConfig) *ProjectProjection

Functions

func Start

func Start(ctx context.Context, es *eventstore.Eventstore, config Config) error

Types

type ActionProjection

type ActionProjection struct {
	crdb.StatementHandler
}

func NewActionProjection

func NewActionProjection(ctx context.Context, config crdb.StatementHandlerConfig) *ActionProjection

type Config

type Config struct {
	RequeueEvery     types.Duration
	RetryFailedAfter types.Duration
	MaxFailureCount  uint
	BulkLimit        uint64
	CRDB             types.SQL
	Customizations   map[string]CustomConfig
}

type CustomConfig

type CustomConfig struct {
	RequeueEvery     *types.Duration
	RetryFailedAfter *types.Duration
	MaxFailureCount  *uint
	BulkLimit        *uint64
}

type OrgProjection

type OrgProjection struct {
	crdb.StatementHandler
}

func NewOrgProjection

func NewOrgProjection(ctx context.Context, config crdb.StatementHandlerConfig) *OrgProjection

type ProjectProjection

type ProjectProjection struct {
	crdb.StatementHandler
}

func NewProjectProjection

func NewProjectProjection(ctx context.Context, config crdb.StatementHandlerConfig) *ProjectProjection