Versions in this module Expand all Collapse all v0 v0.1.0 Sep 6, 2019 Changes in this version + const RemoteErrorAlreadyExists + const RemoteErrorNotFound + const RemoteErrorSystem + const RemoteErrorUser + func IsAlreadyExists(err error) bool + func IsNotFound(err error) bool + func IsUserError(err error) bool + func Wrapf(code ErrorCode, cause error, msg string, args ...interface{}) error + type AdminConfig struct + Burst int + MaxCacheSize int + TPS int64 + func GetAdminConfig() *AdminConfig + func (cfg AdminConfig) GetPFlagSet(prefix string) *pflag.FlagSet + type ErrorCode string + type Executor interface + GetStatus func(ctx context.Context, executionID *core.WorkflowExecutionIdentifier) (*admin.ExecutionClosure, error) + Initialize func(ctx context.Context) error + Kill func(ctx context.Context, executionID *core.WorkflowExecutionIdentifier, ...) error + Launch func(ctx context.Context, launchCtx LaunchContext, ...) error + func NewAdminLaunchPlanExecutor(_ context.Context, client service.AdminServiceClient, syncPeriod time.Duration, ...) (Executor, error) + func NewFailFastLaunchPlanExecutor() Executor + type LaunchContext struct + NestingLevel uint32 + ParentNodeExecution *core.NodeExecutionIdentifier + Principal string + type RemoteError struct + Cause error + Code ErrorCode + Message string + func (r RemoteError) Error() string