Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

dddfirework

package module

Go to main page

Versions in this module

v1

v1.1.0

Oct 24, 2023

Changes in this version

+ var ErrNoEventTimerFound = fmt.Errorf("no event_timer found")

+ type DTimerOption struct

+ func WithTimer(timer ITimer) DTimerOption

+ func (t DTimerOption) ApplyToOptions(opts *Options)

type Engine

+ func (e *Engine) RegisterCronTask(key EventType, cron string, f func(key, cron string))

type EventOption

+ SendTime time.Time

+ type ITimer interface

+ Cancel func(key string) error

+ RegisterTimerHandler func(cb TimerHandler)

+ RunCron func(key, cron string, data []byte) error

+ RunOnce func(key string, t time.Time, data []byte) error

type Options

+ Timer ITimer

type SendType

+ const SendTypeDelay

+ type TimerEvent struct

+ Cron string

+ Key string

+ Payload []byte

+ func (e *TimerEvent) GetSender() string

+ func (e *TimerEvent) GetType() EventType

+ type TimerHandler func(ctx context.Context, key, cron string, data []byte) error

v1.0.0

Oct 9, 2023

Changes in this version

+ const WithRecursiveDelete

+ const WithTransaction

+ const WithoutTransaction

+ var ErrBreak = fmt.Errorf("break process")

+ var ErrEntityNotFound = fmt.Errorf("entity not found")

+ var ErrEntityNotRegister = fmt.Errorf("entity not registered")

+ var ErrEntityRepeated = fmt.Errorf("entity already added")

+ var ErrNoEventBusFound = fmt.Errorf("no eventbus found")

+ func RegisterEventBus(eventBus IEventBus)

+ func RegisterEventHandler(t EventType, handler EventHandler)

+ func RegisterEventTXChecker(t EventType, checker EventTXChecker)

+ type ActFunc func(ctx context.Context, container RootContainer, roots ...IEntity) error

+ type Action struct

+ Models []IModel

+ Op OpType

+ PrevModels []IModel

+ Query IModel

+ QueryResult interface{}

+ type ActionResult struct

+ Data interface{}

+ type BaseEntity struct

+ func NewBase(id string) BaseEntity

+ func (e *BaseEntity) AddEvent(evt IEvent, opts ...EventOpt)

+ func (e *BaseEntity) Dirty()

+ func (e *BaseEntity) GetChildren() map[string][]IEntity

+ func (e *BaseEntity) GetEvents() []*DomainEvent

+ func (e *BaseEntity) GetID() string

+ func (e *BaseEntity) IsDirty() bool

+ func (e *BaseEntity) SetID(id string)

+ func (e *BaseEntity) UnDirty()

+ type BuildFunc func(ctx context.Context, h DomainBuilder) (roots []IEntity, err error)

+ type Command struct

+ func (c *Command) Act(ctx context.Context, container RootContainer, roots ...IEntity) (err error)

+ func (c *Command) Build(ctx context.Context, builder DomainBuilder) (roots []IEntity, err error)

+ func (c *Command) Commit(ctx context.Context) error

+ func (c *Command) Init(ctx context.Context) (lockIDs []string, err error)

+ func (c *Command) Output(data interface{})

+ func (c *Command) PostSave(ctx context.Context, res *Result)

+ func (c *Command) SetStage(s StageAgent)

+ type DomainBuilder struct

+ func (h DomainBuilder) Build(ctx context.Context, parent IEntity, children ...interface{}) error

+ type DomainEvent struct

+ CreatedAt time.Time

+ ID string

+ Payload []byte

+ SendType SendType

+ Sender string

+ Type EventType

+ func NewDomainEvent(event IEvent, opts ...EventOpt) *DomainEvent

+ func (d *DomainEvent) GetSender() string

+ func (d *DomainEvent) GetType() EventType

+ type DomainEventHandler func(ctx context.Context, evt *DomainEvent) error

+ type DomainEventTXChecker func(evt *DomainEvent) TXStatus

+ type Engine struct

+ func NewEngine(l ILock, e IExecutor, opts ...Option) *Engine

+ func (e *Engine) Create(ctx context.Context, roots ...IEntity) *Result

+ func (e *Engine) Delete(ctx context.Context, roots ...IEntity) *Result

+ func (e *Engine) NewStage() *Stage

+ func (e *Engine) RegisterEventHandler(eventType EventType, construct EventHandlerConstruct)

+ func (e *Engine) RunCommand(ctx context.Context, c ICommand, opts ...Option) *Result

+ type EntityContainer struct

+ func (w *EntityContainer) Add(root IEntity) error

+ func (w *EntityContainer) GetChildren() map[string][]IEntity

+ func (w *EntityContainer) GetDeleted() []IEntity

+ func (w *EntityContainer) Recycle(e IEntity)

+ func (w *EntityContainer) Remove(root IEntity) error

+ func (w *EntityContainer) SetChildren(roots []IEntity)

+ type EntitySlice []IEntity

+ type ErrList []error

+ func (e ErrList) Error() string

+ type EventBusOption struct

+ func WithEventBus(eventBus IEventBus) EventBusOption

+ func (t EventBusOption) ApplyToOptions(opts *Options)

+ type EventHandler interface

+ type EventHandlerConstruct interface

+ type EventOpt func(opt *EventOption)

+ func WithSendType(t SendType) EventOpt

+ type EventOption struct

+ SendType SendType

+ type EventPersist func(event *DomainEvent) (IModel, error)

+ type EventSaveOption EventPersist

+ func WithEventPersist(f EventPersist) EventSaveOption

+ func (t EventSaveOption) ApplyToOptions(opts *Options)

+ type EventTXChecker interface

+ type EventType string

+ type IAfterCreate interface

+ AfterCreate func(ctx context.Context) error

+ type IAfterDelete interface

+ AfterDelete func(ctx context.Context) error

+ type IAfterUpdate interface

+ AfterUpdate func(ctx context.Context) error

+ type IBeforeCreate interface

+ BeforeCreate func(ctx context.Context) error

+ type IBeforeDelete interface

+ BeforeDelete func(ctx context.Context) error

+ type IBeforeUpdate interface

+ BeforeUpdate func(ctx context.Context) error

+ type ICommand interface

+ Act func(ctx context.Context, container RootContainer, roots ...IEntity) (err error)

+ Build func(ctx context.Context, builder DomainBuilder) (roots []IEntity, err error)

+ Init func(ctx context.Context) (lockKeys []string, err error)

+ PostSave func(ctx context.Context, res *Result)

+ type IConverter interface

+ Entity2Model func(entity, parent IEntity, op OpType) (IModel, error)

+ Model2Entity func(model IModel, entity IEntity) error

+ type IDGeneratorOption struct

+ func WithIDGenerator(idGen IIDGenerator) IDGeneratorOption

+ func (t IDGeneratorOption) ApplyToOptions(opts *Options)

+ type IDirty interface

+ Dirty func()

+ IsDirty func() bool

+ UnDirty func()

+ type IEntity interface

+ GetChildren func() map[string][]IEntity

+ GetEvents func() []*DomainEvent

+ GetID func() string

+ SetID func(id string)

+ type IEvent interface

+ GetSender func() string

+ GetType func() EventType

+ type IEventBus interface

+ Dispatch func(ctx context.Context, evt ...*DomainEvent) error

+ RegisterEventHandler func(cb DomainEventHandler)

+ type IExecutor interface

+ Exec func(ctx context.Context, actions *Action) error

+ type IIDGenerator interface

+ NewID func() (string, error)

+ type ILock interface

+ Lock func(ctx context.Context, key string) (keyLock interface{}, err error)

+ UnLock func(ctx context.Context, keyLock interface{}) error

+ type IModel interface

+ GetID func() string

+ type IStageSetter interface

+ SetStage func(s StageAgent)

+ type ITransaction interface

+ Begin func(ctx context.Context) (context.Context, error)

+ Commit func(ctx context.Context) error

+ RollBack func(ctx context.Context) error

+ type ITransactionEventBus interface

+ Commit func(ctx context.Context) error

+ DispatchBegin func(ctx context.Context, evt ...*DomainEvent) (context.Context, error)

+ RegisterEventTXChecker func(cb DomainEventTXChecker)

+ Rollback func(ctx context.Context) error

+ type LoggerOption struct

+ func WithLogger(logger logr.Logger) LoggerOption

+ func (t LoggerOption) ApplyToOptions(opts *Options)

+ type OpType int8

+ const OpDelete

+ const OpInsert

+ const OpQuery

+ const OpUnknown

+ const OpUpdate

+ type Option interface

+ ApplyToOptions func(*Options)

+ type Options struct

+ EventBus IEventBus

+ EventPersist EventPersist

+ IDGenerator IIDGenerator

+ Logger logr.Logger

+ PostSaveHooks []PostSaveFunc

+ RecursiveDelete bool

+ WithTransaction bool

+ type PostSaveFunc func(ctx context.Context, res *Result)

+ type PostSaveOption PostSaveFunc

+ func WithPostSave(f PostSaveFunc) PostSaveOption

+ func (t PostSaveOption) ApplyToOptions(opts *Options)

+ type RecursiveDeleteOption bool

+ func (t RecursiveDeleteOption) ApplyToOptions(opts *Options)

+ type Result struct

+ Actions []*Action

+ Break bool

+ Error error

+ Output interface{}

+ func ResultErrOrBreak(err error) *Result

+ func ResultError(err error) *Result

+ func ResultErrors(err ...error) *Result

+ type RootContainer struct

+ func (h *RootContainer) Add(root IEntity)

+ func (h *RootContainer) Remove(root IEntity)

+ type SendType string

+ const SendTypeFIFO

+ const SendTypeNormal

+ const SendTypeTransaction

+ type Stage struct

+ func (e *Stage) Act(f ActFunc) *Stage

+ func (e *Stage) Build(f BuildFunc) *Stage

+ func (e *Stage) BuildEntity(ctx context.Context, parent IEntity, children ...interface{}) error

+ func (e *Stage) Lock(keys ...string) *Stage

+ func (e *Stage) RunCommand(ctx context.Context, c ICommand) *Result

+ func (e *Stage) Save(ctx context.Context) *Result

+ func (e *Stage) WithOption(opts ...Option) *Stage

+ type StageAgent struct

+ func (s *StageAgent) Commit(ctx context.Context) error

+ func (s *StageAgent) Output(data interface{})

+ type TXStatus int

+ const TXCommit

+ const TXRollBack

+ const TXUnknown

+ type TransactionOption bool

+ func (t TransactionOption) ApplyToOptions(opts *Options)