runtime

Documentation

Index

• Variables
• type Form
  • func NewForm() *Form
  • func (f *Form) ID() string
  • func (f *Form) SetMetadata(metedata map[string]interface{}) error
• type Option
• type Runtime
  • func NewRuntime(config *config.Config) (*Runtime, error)
  • func (r *Runtime) Deploy(ctx context.Context, deploy *model.Deployment) (*model.Deployment, error)
  • func (r *Runtime) DeployDelete(ctx context.Context, deploymentID string) error
  • func (r *Runtime) DeployList(ctx context.Context, opts *model.DeploymentListOptions) ([]*model.Deployment, error)
  • func (r *Runtime) NamespaceCreate(ctx context.Context, namespace *model.Namespace) (*model.Namespace, error)
  • func (r *Runtime) NamespaceDelete(ctx context.Context, namespaceID string) error
  • func (r *Runtime) NamespaceGetByID(ctx context.Context, namespaceID string) (*model.Namespace, error)
  • func (r *Runtime) NamespaceGetByName(ctx context.Context, namespaceName string) (*model.Namespace, error)
  • func (r *Runtime) NamespaceList(ctx context.Context, opts *model.NamespaceQueryOptions) ([]*model.Namespace, error)
  • func (r *Runtime) NamespaceListCount(ctx context.Context, opts *model.NamespaceQueryOptions) (int64, error)
  • func (r *Runtime) ProcessDefinitionGet(ctx context.Context, pd *model.ProcessDefinition) (*model.ProcessDefinition, error)
  • func (r *Runtime) ProcessDefinitionStart(ctx context.Context, pd *model.ProcessDefinition) (string, error)
  • func (r *Runtime) ProcessInstanceActivateSuspend(ctx context.Context, pi *model.ProcessInstance) error
  • func (r *Runtime) ProcessInstanceGet(ctx context.Context, pi *model.ProcessInstance) (*model.ProcessInstance, error)
  • func (r *Runtime) RootParsers() map[string]element.Element
  • func (r *Runtime) Run(opts ...Option) error
  • func (r *Runtime) Store() store.Store
  • func (r *Runtime) TaskCreate(ctx context.Context, task *wedo.TaskCreateRequest) (string, error)
  • func (r *Runtime) TaskDelete(ctx context.Context, taskId string) error
  • func (r *Runtime) TaskGet(ctx context.Context, taskId string) (*wedo.TaskResponse, error)
  • func (r *Runtime) TaskList(ctx context.Context, request *wedo.TaskListRequest) ([]*wedo.TaskResponse, error)
  • func (r *Runtime) UserCreate(ctx context.Context, user *model.User) error
  • func (r *Runtime) UserDelete(ctx context.Context, id string) error
  • func (r *Runtime) UserGet(ctx context.Context, id string) (*model.User, error)
  • func (r *Runtime) UserList(ctx context.Context, opts *model.UserListOptions) ([]*model.User, error)
  • func (r *Runtime) UserUpdate(ctx context.Context, user *model.User) error
• type Token

Variables

var (
	ErrInvalidProcessInstanceId = errors.New("invalid process instance id")
)

var (
	ErrNamespaceNameExist = errors.New("namespace name exist")
)

var (
	ErrUserExist = errors.New("user email already exist")
)

Types

type Form

type Form struct {
	FID      string                 `json:"id"`
	Metadata map[string]interface{} `json:"metadata"`
}

func NewForm

func NewForm() *Form

func (*Form) ID

func (f *Form) ID() string

func (*Form) SetMetadata

func (f *Form) SetMetadata(metedata map[string]interface{}) error

type Option

type Option func(o *runtimeOpts)

Option is a function that customizes the runtime.

type Runtime

type Runtime struct {
	// contains filtered or unexported fields
}

func NewRuntime

func NewRuntime(config *config.Config) (*Runtime, error)

func (*Runtime) Deploy

func (r *Runtime) Deploy(ctx context.Context, deploy *model.Deployment) (*model.Deployment, error)

func (*Runtime) DeployDelete

func (r *Runtime) DeployDelete(ctx context.Context, deploymentID string) error

DeployDelete deletes a deployment

func (*Runtime) DeployList

func (r *Runtime) DeployList(ctx context.Context, opts *model.DeploymentListOptions) ([]*model.Deployment, error)

DeployList returns a list of deployments

func (*Runtime) NamespaceCreate

func (r *Runtime) NamespaceCreate(ctx context.Context, namespace *model.Namespace) (*model.Namespace, error)

func (*Runtime) NamespaceDelete

func (r *Runtime) NamespaceDelete(ctx context.Context, namespaceID string) error

NamespaceDelete deletes a namespace

func (*Runtime) NamespaceGetByID

func (r *Runtime) NamespaceGetByID(ctx context.Context, namespaceID string) (*model.Namespace, error)

func (*Runtime) NamespaceGetByName

func (r *Runtime) NamespaceGetByName(ctx context.Context, namespaceName string) (*model.Namespace, error)

func (*Runtime) NamespaceList

func (r *Runtime) NamespaceList(ctx context.Context, opts *model.NamespaceQueryOptions) ([]*model.Namespace, error)

NamespaceList returns a list of namespaces

func (*Runtime) NamespaceListCount

func (r *Runtime) NamespaceListCount(ctx context.Context, opts *model.NamespaceQueryOptions) (int64, error)

NamespaceListCount returns a count of namespaces

func (*Runtime) ProcessDefinitionGet

func (r *Runtime) ProcessDefinitionGet(ctx context.Context, pd *model.ProcessDefinition) (*model.ProcessDefinition, error)

func (*Runtime) ProcessDefinitionStart

func (r *Runtime) ProcessDefinitionStart(ctx context.Context, pd *model.ProcessDefinition) (string, error)

ProcessDefinitionStart Request is the request body for starting a process.

func (*Runtime) ProcessInstanceActivateSuspend

func (r *Runtime) ProcessInstanceActivateSuspend(ctx context.Context, pi *model.ProcessInstance) error

ProcessInstanceActivateSuspend Activate/Suspend process instance

func (*Runtime) ProcessInstanceGet

func (r *Runtime) ProcessInstanceGet(ctx context.Context, pi *model.ProcessInstance) (*model.ProcessInstance, error)

func (*Runtime) RootParsers

func (r *Runtime) RootParsers() map[string]element.Element

func (*Runtime) Run

func (r *Runtime) Run(opts ...Option) error

func (*Runtime) Store

func (r *Runtime) Store() store.Store

func (*Runtime) TaskCreate

func (r *Runtime) TaskCreate(ctx context.Context, task *wedo.TaskCreateRequest) (string, error)

TaskCreate creates a new task.

func (*Runtime) TaskDelete

func (r *Runtime) TaskDelete(ctx context.Context, taskId string) error

TaskDelete deletes a task by id.

func (*Runtime) TaskGet

func (r *Runtime) TaskGet(ctx context.Context, taskId string) (*wedo.TaskResponse, error)

TaskGet gets a task by id.

func (*Runtime) TaskList

func (r *Runtime) TaskList(ctx context.Context, request *wedo.TaskListRequest) ([]*wedo.TaskResponse, error)

TaskList gets a list of tasks by process instance id.

func (*Runtime) UserCreate

func (r *Runtime) UserCreate(ctx context.Context, user *model.User) error

func (*Runtime) UserDelete

func (r *Runtime) UserDelete(ctx context.Context, id string) error

UserDelete deletes a user by ID.

func (*Runtime) UserGet

func (r *Runtime) UserGet(ctx context.Context, id string) (*model.User, error)

UserGet ByID returns a user by ID.

func (*Runtime) UserList

func (r *Runtime) UserList(ctx context.Context, opts *model.UserListOptions) ([]*model.User, error)

UserList returns a list of users.

func (*Runtime) UserUpdate

func (r *Runtime) UserUpdate(ctx context.Context, user *model.User) error

UserUpdate updates a user.

type Token

type Token interface {
	ID() string
	SetMetadata(map[string]interface{}) error
}

Token is token transform between element.