Documentation ¶
Index ¶
- Variables
- func NewOrchestratorActivity(wk libdomain.WorkflowInterface) libdomain.DomainObjectInterface
- func NewOrchestratorWorkflow(wk libdomain.WorkflowInterface) libdomain.DomainObjectInterface
- type DummyStruct
- type OrchestratorActivity
- func (t *OrchestratorActivity) ArgsBinary() []byte
- func (t *OrchestratorActivity) ArgsJson() string
- func (t *OrchestratorActivity) Delete() error
- func (t *OrchestratorActivity) ExternalID() string
- func (t *OrchestratorActivity) ExternalModule() string
- func (t *OrchestratorActivity) GetID() string
- func (t *OrchestratorActivity) ID() string
- func (t *OrchestratorActivity) Init(wk libdomain.WorkflowInterface, pb *pb.OrchestratorActivity)
- func (t *OrchestratorActivity) JSON() ([]byte, error)
- func (t *OrchestratorActivity) Map() map[string]interface{}
- func (t *OrchestratorActivity) OrchestratorWorkflow() *OrchestratorWorkflow
- func (t *OrchestratorActivity) OrchestratorWorkflowID() string
- func (t *OrchestratorActivity) Pb() *pb.OrchestratorActivity
- func (t *OrchestratorActivity) ResultBinary() []byte
- func (t *OrchestratorActivity) ResultJson() string
- func (t *OrchestratorActivity) State() string
- func (t *OrchestratorActivity) Step() int32
- func (t *OrchestratorActivity) Transaction() bool
- func (t *OrchestratorActivity) Update(r *pb.UpdateOrchestratorActivityData) error
- type OrchestratorActivityCollection
- func (c *OrchestratorActivityCollection) Aggregate() libdomain.AggregateInterface
- func (d *OrchestratorActivityCollection) Delete() error
- func (c *OrchestratorActivityCollection) GetByID(id string) *OrchestratorActivity
- func (c *OrchestratorActivityCollection) GetKeys() []string
- func (d *OrchestratorActivityCollection) Map() []map[string]interface{}
- func (t *OrchestratorActivityCollection) OrchestratorWorkflowsByOrchestratorActivityID() (map[string]*OrchestratorWorkflow, error)
- func (c *OrchestratorActivityCollection) Rehydrate(pbOrchestratorActivitys []*pb.OrchestratorActivity)
- func (c *OrchestratorActivityCollection) Slice() []*OrchestratorActivity
- func (c *OrchestratorActivityCollection) SlicePb() []*pb.OrchestratorActivity
- func (d *OrchestratorActivityCollection) Update(r *pb.UpdateOrchestratorActivityData) error
- type OrchestratorActivityFactory
- func (d *OrchestratorActivityFactory) Create(orchestratorActivitys []*pb.CreateOrchestratorActivityCommand, ...) (*OrchestratorActivityCollection, error)
- func (d *OrchestratorActivityFactory) New() *OrchestratorActivity
- func (d *OrchestratorActivityFactory) NewCollection(orchestratorActivitys []*OrchestratorActivity) *OrchestratorActivityCollection
- type OrchestratorActivityFactoryInterface
- type OrchestratorActivityInternalLibrary
- type OrchestratorWorkflow
- func (t *OrchestratorWorkflow) ArgsBinary() []byte
- func (t *OrchestratorWorkflow) ArgsJson() string
- func (t *OrchestratorWorkflow) Delete() error
- func (t *OrchestratorWorkflow) ExternalID() string
- func (t *OrchestratorWorkflow) ExternalModule() string
- func (t *OrchestratorWorkflow) GetID() string
- func (t *OrchestratorWorkflow) ID() string
- func (t *OrchestratorWorkflow) IdempotencyKey() string
- func (t *OrchestratorWorkflow) Init(wk libdomain.WorkflowInterface, pb *pb.OrchestratorWorkflow)
- func (t *OrchestratorWorkflow) JSON() ([]byte, error)
- func (t *OrchestratorWorkflow) Map() map[string]interface{}
- func (t *OrchestratorWorkflow) Name() string
- func (t *OrchestratorWorkflow) Pb() *pb.OrchestratorWorkflow
- func (t *OrchestratorWorkflow) ResultBinary() []byte
- func (t *OrchestratorWorkflow) ResultJson() string
- func (t *OrchestratorWorkflow) State() string
- func (t *OrchestratorWorkflow) Update(r *pb.UpdateOrchestratorWorkflowData) error
- type OrchestratorWorkflowCollection
- func (c *OrchestratorWorkflowCollection) Aggregate() libdomain.AggregateInterface
- func (d *OrchestratorWorkflowCollection) Delete() error
- func (c *OrchestratorWorkflowCollection) GetByID(id string) *OrchestratorWorkflow
- func (c *OrchestratorWorkflowCollection) GetKeys() []string
- func (d *OrchestratorWorkflowCollection) Map() []map[string]interface{}
- func (c *OrchestratorWorkflowCollection) Rehydrate(pbOrchestratorWorkflows []*pb.OrchestratorWorkflow)
- func (c *OrchestratorWorkflowCollection) Slice() []*OrchestratorWorkflow
- func (c *OrchestratorWorkflowCollection) SlicePb() []*pb.OrchestratorWorkflow
- func (d *OrchestratorWorkflowCollection) Update(r *pb.UpdateOrchestratorWorkflowData) error
- type OrchestratorWorkflowFactory
- func (d *OrchestratorWorkflowFactory) Create(orchestratorWorkflows []*pb.CreateOrchestratorWorkflowCommand, ...) (*OrchestratorWorkflowCollection, error)
- func (d *OrchestratorWorkflowFactory) New() *OrchestratorWorkflow
- func (d *OrchestratorWorkflowFactory) NewCollection(orchestratorWorkflows []*OrchestratorWorkflow) *OrchestratorWorkflowCollection
- type OrchestratorWorkflowFactoryInterface
- type OrchestratorWorkflowInternalLibrary
- type PbOrchestratorActivity
- type PbOrchestratorWorkflow
- type TestClientInterface
Constants ¶
This section is empty.
Variables ¶
var OrchestratorActivityAggregate *orchestratorActivityAggregate
OrchestratorActivityAggregate contain the definition of the orchestratorActivity object.
*It is also used to generate the factory containing the main functions with the environnement.
var OrchestratorActivityEntity *orchestratorActivityEntity
var OrchestratorActivityShouldBe func( t *testing.T, ctx context.Context, client TestClientInterface, tenantID string, checkEvents bool, orchestratorActivityFrom *pb.OrchestratorActivity, want *pb.OrchestratorActivity, ) func(t *testing.T)
var OrchestratorWorkflowAggregate *orchestratorWorkflowAggregate
OrchestratorWorkflowAggregate contain the definition of the orchestratorWorkflow object.
*It is also used to generate the factory containing the main functions with the environnement.
var OrchestratorWorkflowEntity *orchestratorWorkflowEntity
var OrchestratorWorkflowShouldBe func( t *testing.T, ctx context.Context, client TestClientInterface, tenantID string, checkEvents bool, orchestratorWorkflowFrom *pb.OrchestratorWorkflow, want *pb.OrchestratorWorkflow, ) func(t *testing.T)
Functions ¶
func NewOrchestratorActivity ¶
func NewOrchestratorActivity(wk libdomain.WorkflowInterface) libdomain.DomainObjectInterface
func NewOrchestratorWorkflow ¶
func NewOrchestratorWorkflow(wk libdomain.WorkflowInterface) libdomain.DomainObjectInterface
Types ¶
type DummyStruct ¶
type DummyStruct struct{}
type OrchestratorActivity ¶
type OrchestratorActivity struct { Workflow libdomain.WorkflowInterface // contains filtered or unexported fields }
OrchestratorActivity is the main struct for operating a orchestratorActivity object, which shall
*be used in custom code because it contains the environnement informations and *the easy-to-use functions.
func (*OrchestratorActivity) ArgsBinary ¶
func (t *OrchestratorActivity) ArgsBinary() []byte
func (*OrchestratorActivity) ArgsJson ¶
func (t *OrchestratorActivity) ArgsJson() string
func (*OrchestratorActivity) Delete ¶
func (t *OrchestratorActivity) Delete() error
Delete will delete the orchestratorActivity from the database.
func (*OrchestratorActivity) ExternalID ¶
func (t *OrchestratorActivity) ExternalID() string
func (*OrchestratorActivity) ExternalModule ¶
func (t *OrchestratorActivity) ExternalModule() string
func (*OrchestratorActivity) GetID ¶
func (t *OrchestratorActivity) GetID() string
func (*OrchestratorActivity) ID ¶
func (t *OrchestratorActivity) ID() string
SetID is a function to set the ID of the orchestratorActivity.
func (*OrchestratorActivity) Init ¶
func (t *OrchestratorActivity) Init(wk libdomain.WorkflowInterface, pb *pb.OrchestratorActivity)
func (*OrchestratorActivity) JSON ¶
func (t *OrchestratorActivity) JSON() ([]byte, error)
JSON is a function to return the orchestratorActivity data in JSON format.
func (*OrchestratorActivity) Map ¶
func (t *OrchestratorActivity) Map() map[string]interface{}
Map is a function to return the orchestratorActivity data in JSON format.
func (*OrchestratorActivity) OrchestratorWorkflow ¶
func (t *OrchestratorActivity) OrchestratorWorkflow() *OrchestratorWorkflow
func (*OrchestratorActivity) OrchestratorWorkflowID ¶
func (t *OrchestratorActivity) OrchestratorWorkflowID() string
func (*OrchestratorActivity) Pb ¶
func (t *OrchestratorActivity) Pb() *pb.OrchestratorActivity
SetID is a function to set the ID of the orchestratorActivity.
func (*OrchestratorActivity) ResultBinary ¶
func (t *OrchestratorActivity) ResultBinary() []byte
func (*OrchestratorActivity) ResultJson ¶
func (t *OrchestratorActivity) ResultJson() string
func (*OrchestratorActivity) State ¶
func (t *OrchestratorActivity) State() string
func (*OrchestratorActivity) Step ¶
func (t *OrchestratorActivity) Step() int32
func (*OrchestratorActivity) Transaction ¶
func (t *OrchestratorActivity) Transaction() bool
func (*OrchestratorActivity) Update ¶
func (t *OrchestratorActivity) Update(r *pb.UpdateOrchestratorActivityData) error
Delete will delete the orchestratorActivity from the database.
type OrchestratorActivityCollection ¶
type OrchestratorActivityCollection struct { //*libdomain.Collection // OrchestratorActivityCollectionInterface Workflow libdomain.WorkflowInterface // contains filtered or unexported fields }
OrchestratorActivityCollection is the main struct for operating a list orchestratorActivity object, which shall
*be used in custom code because it contains the environnement informations and *the easy-to-use functions.
func (*OrchestratorActivityCollection) Aggregate ¶
func (c *OrchestratorActivityCollection) Aggregate() libdomain.AggregateInterface
func (*OrchestratorActivityCollection) Delete ¶
func (d *OrchestratorActivityCollection) Delete() error
Delete will delete all the orchestratorActivitys in the collection.
func (*OrchestratorActivityCollection) GetByID ¶
func (c *OrchestratorActivityCollection) GetByID(id string) *OrchestratorActivity
GetByID return the orchestratorActivity in this collection, by id.
func (*OrchestratorActivityCollection) GetKeys ¶
func (c *OrchestratorActivityCollection) GetKeys() []string
GetByID return the orchestratorActivity in this collection, by id.
func (*OrchestratorActivityCollection) Map ¶
func (d *OrchestratorActivityCollection) Map() []map[string]interface{}
func (*OrchestratorActivityCollection) OrchestratorWorkflowsByOrchestratorActivityID ¶
func (t *OrchestratorActivityCollection) OrchestratorWorkflowsByOrchestratorActivityID() (map[string]*OrchestratorWorkflow, error)
OrchestratorWorkflowsByOrchestratorActivityID return the orchestratorWorkflow behind OrchestratorWorkflowID field, for each orchestratorActivity in the collection, by id.
func (*OrchestratorActivityCollection) Rehydrate ¶
func (c *OrchestratorActivityCollection) Rehydrate(pbOrchestratorActivitys []*pb.OrchestratorActivity)
func (*OrchestratorActivityCollection) Slice ¶
func (c *OrchestratorActivityCollection) Slice() []*OrchestratorActivity
GetSlice return all orchestratorActivitys in this collection, as a slice.
func (*OrchestratorActivityCollection) SlicePb ¶
func (c *OrchestratorActivityCollection) SlicePb() []*pb.OrchestratorActivity
GetSlice return all orchestratorActivitys in this collection, as a slice.
func (*OrchestratorActivityCollection) Update ¶
func (d *OrchestratorActivityCollection) Update(r *pb.UpdateOrchestratorActivityData) error
Update will update all the orchestratorActivitys in the collection with the specified data.
type OrchestratorActivityFactory ¶
type OrchestratorActivityFactory struct { *libdomain.Factory OrchestratorActivityFactoryInterface }
OrchestratorActivityFactory is the main struct for operating orchestratorActivity objects, which shall
*be used in custom code because it contains the environnement informations and *the easy-to-use functions.
func (*OrchestratorActivityFactory) Create ¶
func (d *OrchestratorActivityFactory) Create( orchestratorActivitys []*pb.CreateOrchestratorActivityCommand, parentAggregate *libdomain.AggregateDefinition, ) (*OrchestratorActivityCollection, error)
Create create a new orchestratorActivity from the factory, and return it.
func (*OrchestratorActivityFactory) New ¶
func (d *OrchestratorActivityFactory) New() *OrchestratorActivity
New return a new instance of a orchestratorActivity object.
func (*OrchestratorActivityFactory) NewCollection ¶
func (d *OrchestratorActivityFactory) NewCollection(orchestratorActivitys []*OrchestratorActivity) *OrchestratorActivityCollection
NewCollection return a new instance of a orchestratorActivity collection object.
type OrchestratorActivityFactoryInterface ¶
type OrchestratorActivityFactoryInterface interface { }
type OrchestratorActivityInternalLibrary ¶
type OrchestratorActivityInternalLibrary struct { }
type OrchestratorWorkflow ¶
type OrchestratorWorkflow struct { Workflow libdomain.WorkflowInterface // contains filtered or unexported fields }
OrchestratorWorkflow is the main struct for operating a orchestratorWorkflow object, which shall
*be used in custom code because it contains the environnement informations and *the easy-to-use functions.
func (*OrchestratorWorkflow) ArgsBinary ¶
func (t *OrchestratorWorkflow) ArgsBinary() []byte
func (*OrchestratorWorkflow) ArgsJson ¶
func (t *OrchestratorWorkflow) ArgsJson() string
func (*OrchestratorWorkflow) Delete ¶
func (t *OrchestratorWorkflow) Delete() error
Delete will delete the orchestratorWorkflow from the database.
func (*OrchestratorWorkflow) ExternalID ¶
func (t *OrchestratorWorkflow) ExternalID() string
func (*OrchestratorWorkflow) ExternalModule ¶
func (t *OrchestratorWorkflow) ExternalModule() string
func (*OrchestratorWorkflow) GetID ¶
func (t *OrchestratorWorkflow) GetID() string
func (*OrchestratorWorkflow) ID ¶
func (t *OrchestratorWorkflow) ID() string
SetID is a function to set the ID of the orchestratorWorkflow.
func (*OrchestratorWorkflow) IdempotencyKey ¶
func (t *OrchestratorWorkflow) IdempotencyKey() string
func (*OrchestratorWorkflow) Init ¶
func (t *OrchestratorWorkflow) Init(wk libdomain.WorkflowInterface, pb *pb.OrchestratorWorkflow)
func (*OrchestratorWorkflow) JSON ¶
func (t *OrchestratorWorkflow) JSON() ([]byte, error)
JSON is a function to return the orchestratorWorkflow data in JSON format.
func (*OrchestratorWorkflow) Map ¶
func (t *OrchestratorWorkflow) Map() map[string]interface{}
Map is a function to return the orchestratorWorkflow data in JSON format.
func (*OrchestratorWorkflow) Name ¶
func (t *OrchestratorWorkflow) Name() string
func (*OrchestratorWorkflow) Pb ¶
func (t *OrchestratorWorkflow) Pb() *pb.OrchestratorWorkflow
SetID is a function to set the ID of the orchestratorWorkflow.
func (*OrchestratorWorkflow) ResultBinary ¶
func (t *OrchestratorWorkflow) ResultBinary() []byte
func (*OrchestratorWorkflow) ResultJson ¶
func (t *OrchestratorWorkflow) ResultJson() string
func (*OrchestratorWorkflow) State ¶
func (t *OrchestratorWorkflow) State() string
func (*OrchestratorWorkflow) Update ¶
func (t *OrchestratorWorkflow) Update(r *pb.UpdateOrchestratorWorkflowData) error
Delete will delete the orchestratorWorkflow from the database.
type OrchestratorWorkflowCollection ¶
type OrchestratorWorkflowCollection struct { //*libdomain.Collection // OrchestratorWorkflowCollectionInterface Workflow libdomain.WorkflowInterface // contains filtered or unexported fields }
OrchestratorWorkflowCollection is the main struct for operating a list orchestratorWorkflow object, which shall
*be used in custom code because it contains the environnement informations and *the easy-to-use functions.
func (*OrchestratorWorkflowCollection) Aggregate ¶
func (c *OrchestratorWorkflowCollection) Aggregate() libdomain.AggregateInterface
func (*OrchestratorWorkflowCollection) Delete ¶
func (d *OrchestratorWorkflowCollection) Delete() error
Delete will delete all the orchestratorWorkflows in the collection.
func (*OrchestratorWorkflowCollection) GetByID ¶
func (c *OrchestratorWorkflowCollection) GetByID(id string) *OrchestratorWorkflow
GetByID return the orchestratorWorkflow in this collection, by id.
func (*OrchestratorWorkflowCollection) GetKeys ¶
func (c *OrchestratorWorkflowCollection) GetKeys() []string
GetByID return the orchestratorWorkflow in this collection, by id.
func (*OrchestratorWorkflowCollection) Map ¶
func (d *OrchestratorWorkflowCollection) Map() []map[string]interface{}
func (*OrchestratorWorkflowCollection) Rehydrate ¶
func (c *OrchestratorWorkflowCollection) Rehydrate(pbOrchestratorWorkflows []*pb.OrchestratorWorkflow)
func (*OrchestratorWorkflowCollection) Slice ¶
func (c *OrchestratorWorkflowCollection) Slice() []*OrchestratorWorkflow
GetSlice return all orchestratorWorkflows in this collection, as a slice.
func (*OrchestratorWorkflowCollection) SlicePb ¶
func (c *OrchestratorWorkflowCollection) SlicePb() []*pb.OrchestratorWorkflow
GetSlice return all orchestratorWorkflows in this collection, as a slice.
func (*OrchestratorWorkflowCollection) Update ¶
func (d *OrchestratorWorkflowCollection) Update(r *pb.UpdateOrchestratorWorkflowData) error
Update will update all the orchestratorWorkflows in the collection with the specified data.
type OrchestratorWorkflowFactory ¶
type OrchestratorWorkflowFactory struct { *libdomain.Factory OrchestratorWorkflowFactoryInterface }
OrchestratorWorkflowFactory is the main struct for operating orchestratorWorkflow objects, which shall
*be used in custom code because it contains the environnement informations and *the easy-to-use functions.
func (*OrchestratorWorkflowFactory) Create ¶
func (d *OrchestratorWorkflowFactory) Create( orchestratorWorkflows []*pb.CreateOrchestratorWorkflowCommand, parentAggregate *libdomain.AggregateDefinition, ) (*OrchestratorWorkflowCollection, error)
Create create a new orchestratorWorkflow from the factory, and return it.
func (*OrchestratorWorkflowFactory) New ¶
func (d *OrchestratorWorkflowFactory) New() *OrchestratorWorkflow
New return a new instance of a orchestratorWorkflow object.
func (*OrchestratorWorkflowFactory) NewCollection ¶
func (d *OrchestratorWorkflowFactory) NewCollection(orchestratorWorkflows []*OrchestratorWorkflow) *OrchestratorWorkflowCollection
NewCollection return a new instance of a orchestratorWorkflow collection object.
type OrchestratorWorkflowFactoryInterface ¶
type OrchestratorWorkflowFactoryInterface interface { }
type OrchestratorWorkflowInternalLibrary ¶
type OrchestratorWorkflowInternalLibrary struct { }
type PbOrchestratorActivity ¶
type PbOrchestratorActivity = pb.OrchestratorActivity
type PbOrchestratorWorkflow ¶
type PbOrchestratorWorkflow = pb.OrchestratorWorkflow
type TestClientInterface ¶
type TestClientInterface interface { }