libgrpc

type ActivityInterface interface {
	MarshalArgs() ([]byte, error)
	UnmarshalArgs([]byte) error
	MarshalResult(interface{}) ([]byte, error)
	UnmarshalResult([]byte, interface{}) error
	Run(context.Context) (interface{}, error)
}

type ActivityRunInterface interface {
}

type Arg struct {
	Name     string
	Type     libdomain.PropertyType
	Required bool
}

type ArgData struct {
	Name     string
	Title    string
	Type     string
	Required bool
	Arg      *Arg
}

type CustomFunc struct {
	Name   string
	Args   []*Arg
	Result *Arg
}

type CustomFuncData struct {
	Name   string
	Title  string
	Args   []*ArgData
	Result *ArgData
}

type Definition struct {
	Application    libapplication.AggregateInterface
	GenDomain      string
	Create         *RequestConfig
	Update         *RequestConfig
	Delete         *RequestConfig
	CustomQueries  []*libdomain.CustomRequest
	CustomCommands []*libdomain.CustomRequest

	Event bool
	// contains filtered or unexported fields
}

type Definitions struct {
	Prefix     string
	Repository string
	Tenant     bool
	Auth       bool
	// contains filtered or unexported fields
}

type OrchestratorClient interface {
	ExecuteWorkflow(
		context.Context, *libdomain.AggregateDefinition, string, string,
		WorkflowInterface, StartWorkflowOptions) (WorkflowRunInterface, error)
	ExecuteActivity(*libdomain.Workflow, ActivityInterface) (ActivityRunInterface, error)
	InitOrchestratorRepository() error
}

type RequestConfig struct{}

type Server struct {
}

type StartWorkflowOptions struct {
	ID       string
	Model    string
	Function string
}

type WorkerInterface interface {
	RegisterWorkflow(string, string, interface{}) error
	RegisterActivity(a interface{}) error
	Run(i <-chan interface{}) error
}

type WorkflowInterface interface {
	GetName() string
	MarshalArgs() ([]byte, error)
	UnmarshalArgs([]byte) error
	MarshalResult(interface{}) ([]byte, error)
	UnmarshalResult([]byte, interface{}) error
	Run(*libdomain.Workflow) (interface{}, error)
}

type WorkflowRunInterface interface {
	Get(context.Context) (interface{}, error)
}