pb

package module
v0.0.0-...-6caef8a Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Nov 9, 2024 License: Apache-2.0 Imports: 16 Imported by: 0

Documentation

Overview

Package pb is a generated GoMock package.

Index

Constants

This section is empty.

Variables

View Source 
var (
	ErrorCode_name = map[int32]string{
		0:    "OK",
		1000: "UnknownError",
		1001: "InternelError",
		1002: "ExecutionNotFound",
		1003: "StepNotFound",
		1004: "StepGroupNotFound",
		1005: "TaskTokenNotFound",
		1006: "NamespaceNotFound",
		1007: "ActivityNotFound",
		1008: "WorkflowNotFound",
		1009: "ExecutionUUIDExisted",
		1010: "ActivityTaskNotFound",
		1011: "StepStatusError",
		1012: "ExecutionStatusError",
		1013: "ParameterIsVaild",
		1014: "ParameterLimitExceeded",
		1015: "InputLimitExceeded",
		1016: "OutputLimitExceeded",
		1017: "WorkflowDeinitionInvalid",
		2000: "ResourceLimitExceeded",
	}
	ErrorCode_value = map[string]int32{
		"OK":                       0,
		"UnknownError":             1000,
		"InternelError":            1001,
		"ExecutionNotFound":        1002,
		"StepNotFound":             1003,
		"StepGroupNotFound":        1004,
		"TaskTokenNotFound":        1005,
		"NamespaceNotFound":        1006,
		"ActivityNotFound":         1007,
		"WorkflowNotFound":         1008,
		"ExecutionUUIDExisted":     1009,
		"ActivityTaskNotFound":     1010,
		"StepStatusError":          1011,
		"ExecutionStatusError":     1012,
		"ParameterIsVaild":         1013,
		"ParameterLimitExceeded":   1014,
		"InputLimitExceeded":       1015,
		"OutputLimitExceeded":      1016,
		"WorkflowDeinitionInvalid": 1017,
		"ResourceLimitExceeded":    2000,
	}
)

Enum value maps for ErrorCode.

View Source 
var CommonServer_ServiceDesc = server.ServiceDesc{
	ServiceName: "skyflow.Common",
	HandlerType: ((*CommonService)(nil)),
	Methods: []server.Method{
		{
			Name: "/skyflow.Common/Paging",
			Func: CommonService_Paging_Handler,
		},
		{
			Name: "/skyflow.Common/HTTP",
			Func: CommonService_HTTP_Handler,
		},
	},
}

CommonServer_ServiceDesc descriptor for server.RegisterService.

View Source 
var File_proto_skyflow_proto protoreflect.FileDescriptor
View Source 
var NewCommonClientProxy = func(opts ...client.Option) CommonClientProxy {
	return &CommonClientProxyImpl{client: client.DefaultClient, opts: opts}
}
View Source 
var NewSkyflowClientProxy = func(opts ...client.Option) SkyflowClientProxy {
	return &SkyflowClientProxyImpl{client: client.DefaultClient, opts: opts}
}
View Source 
var SkyflowServer_ServiceDesc = server.ServiceDesc{
	ServiceName: "skyflow.Skyflow",
	HandlerType: ((*SkyflowService)(nil)),
	Methods: []server.Method{
		{
			Name: "/api/v1/CreateNamespace",
			Func: SkyflowService_CreateNamespace_Handler,
		},
		{
			Name: "/api/v1/ListNamespaces",
			Func: SkyflowService_ListNamespaces_Handler,
		},
		{
			Name: "/api/v1/CreateActivity",
			Func: SkyflowService_CreateActivity_Handler,
		},
		{
			Name: "/api/v1/ListActivities",
			Func: SkyflowService_ListActivities_Handler,
		},
		{
			Name: "/api/v1/DescribeActivity",
			Func: SkyflowService_DescribeActivity_Handler,
		},
		{
			Name: "/skyflow.Skyflow/CreateNamespace",
			Func: SkyflowService_CreateNamespace_Handler,
		},
		{
			Name: "/skyflow.Skyflow/ListNamespaces",
			Func: SkyflowService_ListNamespaces_Handler,
		},
		{
			Name: "/skyflow.Skyflow/CreateActivity",
			Func: SkyflowService_CreateActivity_Handler,
		},
		{
			Name: "/skyflow.Skyflow/ListActivities",
			Func: SkyflowService_ListActivities_Handler,
		},
		{
			Name: "/skyflow.Skyflow/DescribeActivity",
			Func: SkyflowService_DescribeActivity_Handler,
		},
	},
}

SkyflowServer_ServiceDesc descriptor for server.RegisterService.

Functions

func CommonService_HTTP_Handler 

func CommonService_HTTP_Handler(svr interface{}, ctx context.Context, f server.FilterFunc) (interface{}, error)

func CommonService_Paging_Handler 

func CommonService_Paging_Handler(svr interface{}, ctx context.Context, f server.FilterFunc) (interface{}, error)

func RegisterCommonService 

func RegisterCommonService(s server.Service, svr CommonService)

RegisterCommonService registers service.

func RegisterSkyflowService 

func RegisterSkyflowService(s server.Service, svr SkyflowService)

RegisterSkyflowService registers service.

func SkyflowService_CreateActivity_Handler 

func SkyflowService_CreateActivity_Handler(svr interface{}, ctx context.Context, f server.FilterFunc) (interface{}, error)

func SkyflowService_CreateNamespace_Handler 

func SkyflowService_CreateNamespace_Handler(svr interface{}, ctx context.Context, f server.FilterFunc) (interface{}, error)

func SkyflowService_DescribeActivity_Handler 

func SkyflowService_DescribeActivity_Handler(svr interface{}, ctx context.Context, f server.FilterFunc) (interface{}, error)

func SkyflowService_ListActivities_Handler 

func SkyflowService_ListActivities_Handler(svr interface{}, ctx context.Context, f server.FilterFunc) (interface{}, error)

func SkyflowService_ListNamespaces_Handler 

func SkyflowService_ListNamespaces_Handler(svr interface{}, ctx context.Context, f server.FilterFunc) (interface{}, error)

Types

type ActivityInfo 

type ActivityInfo struct {
	Name        string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Comment     string `protobuf:"bytes,2,opt,name=comment,proto3" json:"comment,omitempty"`
	ActivityUri string `protobuf:"bytes,3,opt,name=activity_uri,json=activityUri,proto3" json:"activity_uri,omitempty"`
	CreateTime  string `protobuf:"bytes,11,opt,name=create_time,json=createTime,proto3" json:"create_time,omitempty"`
	ModifyTime  string `protobuf:"bytes,12,opt,name=modify_time,json=modifyTime,proto3" json:"modify_time,omitempty"`
	// contains filtered or unexported fields
}

ActivityInfo 活动信息

func (*ActivityInfo) Descriptor deprecated 

func (*ActivityInfo) Descriptor() ([]byte, []int)

Deprecated: Use ActivityInfo.ProtoReflect.Descriptor instead.

func (*ActivityInfo) GetActivityUri 

func (x *ActivityInfo) GetActivityUri() string

func (*ActivityInfo) GetComment 

func (x *ActivityInfo) GetComment() string

func (*ActivityInfo) GetCreateTime 

func (x *ActivityInfo) GetCreateTime() string

func (*ActivityInfo) GetModifyTime 

func (x *ActivityInfo) GetModifyTime() string

func (*ActivityInfo) GetName 

func (x *ActivityInfo) GetName() string

func (*ActivityInfo) ProtoMessage 

func (*ActivityInfo) ProtoMessage()

func (*ActivityInfo) ProtoReflect 

func (x *ActivityInfo) ProtoReflect() protoreflect.Message

func (*ActivityInfo) Reset 

func (x *ActivityInfo) Reset()

func (*ActivityInfo) String 

func (x *ActivityInfo) String() string

type ActivityListItem 

type ActivityListItem struct {
	Name        string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Comment     string `protobuf:"bytes,2,opt,name=comment,proto3" json:"comment,omitempty"`
	ActivityUri string `protobuf:"bytes,3,opt,name=activity_uri,json=activityUri,proto3" json:"activity_uri,omitempty"`
	CreateTime  string `protobuf:"bytes,11,opt,name=create_time,json=createTime,proto3" json:"create_time,omitempty"`
	ModifyTime  string `protobuf:"bytes,12,opt,name=modify_time,json=modifyTime,proto3" json:"modify_time,omitempty"`
	// contains filtered or unexported fields
}

ActivityListItem ...

func (*ActivityListItem) Descriptor deprecated 

func (*ActivityListItem) Descriptor() ([]byte, []int)

Deprecated: Use ActivityListItem.ProtoReflect.Descriptor instead.

func (*ActivityListItem) GetActivityUri 

func (x *ActivityListItem) GetActivityUri() string

func (*ActivityListItem) GetComment 

func (x *ActivityListItem) GetComment() string

func (*ActivityListItem) GetCreateTime 

func (x *ActivityListItem) GetCreateTime() string

func (*ActivityListItem) GetModifyTime 

func (x *ActivityListItem) GetModifyTime() string

func (*ActivityListItem) GetName 

func (x *ActivityListItem) GetName() string

func (*ActivityListItem) ProtoMessage 

func (*ActivityListItem) ProtoMessage()

func (*ActivityListItem) ProtoReflect 

func (x *ActivityListItem) ProtoReflect() protoreflect.Message

func (*ActivityListItem) Reset 

func (x *ActivityListItem) Reset()

func (*ActivityListItem) String 

func (x *ActivityListItem) String() string

type CommonClientProxy 

type CommonClientProxy interface {
	// Paging Paging 分页格式
	Paging(ctx context.Context, req *PageRequest, opts ...client.Option) (rsp *PageResponse, err error)
	// HTTP HTTPReturn  HTTP API接口返回值格式
	HTTP(ctx context.Context, req *emptypb.Empty, opts ...client.Option) (rsp *HTTPResponseMessage, err error)
}

CommonClientProxy defines service client proxy

type CommonClientProxyImpl 

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

func (*CommonClientProxyImpl) HTTP 

func (c *CommonClientProxyImpl) HTTP(ctx context.Context, req *emptypb.Empty, opts ...client.Option) (*HTTPResponseMessage, error)

func (*CommonClientProxyImpl) Paging 

func (c *CommonClientProxyImpl) Paging(ctx context.Context, req *PageRequest, opts ...client.Option) (*PageResponse, error)

type CommonService 

type CommonService interface {
	// Paging Paging 分页格式
	Paging(ctx context.Context, req *PageRequest) (*PageResponse, error)
	// HTTP HTTPReturn  HTTP API接口返回值格式
	HTTP(ctx context.Context, req *emptypb.Empty) (*HTTPResponseMessage, error)
}

CommonService defines service.

type CreateActivityRequest 

type CreateActivityRequest struct {
	Name      string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Comment   string `protobuf:"bytes,2,opt,name=comment,proto3" json:"comment,omitempty"`
	Namespace string `protobuf:"bytes,3,opt,name=namespace,proto3" json:"namespace,omitempty"`
	// contains filtered or unexported fields
}

CreateActivityRequest 创建一个活动请求结构

func (*CreateActivityRequest) Descriptor deprecated 

func (*CreateActivityRequest) Descriptor() ([]byte, []int)

Deprecated: Use CreateActivityRequest.ProtoReflect.Descriptor instead.

func (*CreateActivityRequest) GetComment 

func (x *CreateActivityRequest) GetComment() string

func (*CreateActivityRequest) GetName 

func (x *CreateActivityRequest) GetName() string

func (*CreateActivityRequest) GetNamespace 

func (x *CreateActivityRequest) GetNamespace() string

func (*CreateActivityRequest) ProtoMessage 

func (*CreateActivityRequest) ProtoMessage()

func (*CreateActivityRequest) ProtoReflect 

func (x *CreateActivityRequest) ProtoReflect() protoreflect.Message

func (*CreateActivityRequest) Reset 

func (x *CreateActivityRequest) Reset()

func (*CreateActivityRequest) String 

func (x *CreateActivityRequest) String() string

type CreateActivityResponse 

type CreateActivityResponse struct {
	Data *ActivityInfo `protobuf:"bytes,1,opt,name=data,proto3" json:"data,omitempty"`
	// contains filtered or unexported fields
}

CreateActivityResponse 创建一个活动返回结构

func (*CreateActivityResponse) Descriptor deprecated 

func (*CreateActivityResponse) Descriptor() ([]byte, []int)

Deprecated: Use CreateActivityResponse.ProtoReflect.Descriptor instead.

func (*CreateActivityResponse) GetData 

func (x *CreateActivityResponse) GetData() *ActivityInfo

func (*CreateActivityResponse) ProtoMessage 

func (*CreateActivityResponse) ProtoMessage()

func (*CreateActivityResponse) ProtoReflect 

func (x *CreateActivityResponse) ProtoReflect() protoreflect.Message

func (*CreateActivityResponse) Reset 

func (x *CreateActivityResponse) Reset()

func (*CreateActivityResponse) String 

func (x *CreateActivityResponse) String() string

type CreateNamespaceRequest 

type CreateNamespaceRequest struct {
	Name    string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Comment string `protobuf:"bytes,2,opt,name=comment,proto3" json:"comment,omitempty"`
	// contains filtered or unexported fields
}

CreateNamespaceRequest 创建一个命名空间

func (*CreateNamespaceRequest) Descriptor deprecated 

func (*CreateNamespaceRequest) Descriptor() ([]byte, []int)

Deprecated: Use CreateNamespaceRequest.ProtoReflect.Descriptor instead.

func (*CreateNamespaceRequest) GetComment 

func (x *CreateNamespaceRequest) GetComment() string

func (*CreateNamespaceRequest) GetName 

func (x *CreateNamespaceRequest) GetName() string

func (*CreateNamespaceRequest) ProtoMessage 

func (*CreateNamespaceRequest) ProtoMessage()

func (*CreateNamespaceRequest) ProtoReflect 

func (x *CreateNamespaceRequest) ProtoReflect() protoreflect.Message

func (*CreateNamespaceRequest) Reset 

func (x *CreateNamespaceRequest) Reset()

func (*CreateNamespaceRequest) String 

func (x *CreateNamespaceRequest) String() string

type CreateNamespaceResponse 

type CreateNamespaceResponse struct {
	Data *NamespaceInfo `protobuf:"bytes,1,opt,name=data,proto3" json:"data,omitempty"`
	// contains filtered or unexported fields
}

CreateNamespaceResponse 创建一个命名空间返回结构

func (*CreateNamespaceResponse) Descriptor deprecated 

func (*CreateNamespaceResponse) Descriptor() ([]byte, []int)

Deprecated: Use CreateNamespaceResponse.ProtoReflect.Descriptor instead.

func (*CreateNamespaceResponse) GetData 

func (x *CreateNamespaceResponse) GetData() *NamespaceInfo

func (*CreateNamespaceResponse) ProtoMessage 

func (*CreateNamespaceResponse) ProtoMessage()

func (*CreateNamespaceResponse) ProtoReflect 

func (x *CreateNamespaceResponse) ProtoReflect() protoreflect.Message

func (*CreateNamespaceResponse) Reset 

func (x *CreateNamespaceResponse) Reset()

func (*CreateNamespaceResponse) String 

func (x *CreateNamespaceResponse) String() string

type CreateWorkflowRequest 

type CreateWorkflowRequest struct {
	Name               string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Comment            string `protobuf:"bytes,2,opt,name=comment,proto3" json:"comment,omitempty"`
	Namespace          string `protobuf:"bytes,3,opt,name=namespace,proto3" json:"namespace,omitempty"`
	WorkflowDefinition string `protobuf:"bytes,4,opt,name=workflow_definition,json=workflowDefinition,proto3" json:"workflow_definition,omitempty"`
	// contains filtered or unexported fields
}

CreateWorkflowRequest 创建一个工作流请求结构

func (*CreateWorkflowRequest) Descriptor deprecated 

func (*CreateWorkflowRequest) Descriptor() ([]byte, []int)

Deprecated: Use CreateWorkflowRequest.ProtoReflect.Descriptor instead.

func (*CreateWorkflowRequest) GetComment 

func (x *CreateWorkflowRequest) GetComment() string

func (*CreateWorkflowRequest) GetName 

func (x *CreateWorkflowRequest) GetName() string

func (*CreateWorkflowRequest) GetNamespace 

func (x *CreateWorkflowRequest) GetNamespace() string

func (*CreateWorkflowRequest) GetWorkflowDefinition 

func (x *CreateWorkflowRequest) GetWorkflowDefinition() string

func (*CreateWorkflowRequest) ProtoMessage 

func (*CreateWorkflowRequest) ProtoMessage()

func (*CreateWorkflowRequest) ProtoReflect 

func (x *CreateWorkflowRequest) ProtoReflect() protoreflect.Message

func (*CreateWorkflowRequest) Reset 

func (x *CreateWorkflowRequest) Reset()

func (*CreateWorkflowRequest) String 

func (x *CreateWorkflowRequest) String() string

type CreateWorkflowResponse 

type CreateWorkflowResponse struct {
	Data *WorkflowInfo `protobuf:"bytes,1,opt,name=data,proto3" json:"data,omitempty"`
	// contains filtered or unexported fields
}

CreateWorkflowResponse 创建一个工作流返回结构

func (*CreateWorkflowResponse) Descriptor deprecated 

func (*CreateWorkflowResponse) Descriptor() ([]byte, []int)

Deprecated: Use CreateWorkflowResponse.ProtoReflect.Descriptor instead.

func (*CreateWorkflowResponse) GetData 

func (x *CreateWorkflowResponse) GetData() *WorkflowInfo

func (*CreateWorkflowResponse) ProtoMessage 

func (*CreateWorkflowResponse) ProtoMessage()

func (*CreateWorkflowResponse) ProtoReflect 

func (x *CreateWorkflowResponse) ProtoReflect() protoreflect.Message

func (*CreateWorkflowResponse) Reset 

func (x *CreateWorkflowResponse) Reset()

func (*CreateWorkflowResponse) String 

func (x *CreateWorkflowResponse) String() string

type DescribeActivityRequest 

type DescribeActivityRequest struct {

	// activity uri
	ActivityUri string `protobuf:"bytes,1,opt,name=activity_uri,json=activityUri,proto3" json:"activity_uri,omitempty"`
	// contains filtered or unexported fields
}

DescribeActivityRequest 获得活动详情

func (*DescribeActivityRequest) Descriptor deprecated 

func (*DescribeActivityRequest) Descriptor() ([]byte, []int)

Deprecated: Use DescribeActivityRequest.ProtoReflect.Descriptor instead.

func (*DescribeActivityRequest) GetActivityUri 

func (x *DescribeActivityRequest) GetActivityUri() string

func (*DescribeActivityRequest) ProtoMessage 

func (*DescribeActivityRequest) ProtoMessage()

func (*DescribeActivityRequest) ProtoReflect 

func (x *DescribeActivityRequest) ProtoReflect() protoreflect.Message

func (*DescribeActivityRequest) Reset 

func (x *DescribeActivityRequest) Reset()

func (*DescribeActivityRequest) String 

func (x *DescribeActivityRequest) String() string

type DescribeActivityResponse 

type DescribeActivityResponse struct {
	Data *ActivityInfo `protobuf:"bytes,1,opt,name=data,proto3" json:"data,omitempty"`
	// contains filtered or unexported fields
}

DescribeActivityResponse 获得活动列表请求返回

func (*DescribeActivityResponse) Descriptor deprecated 

func (*DescribeActivityResponse) Descriptor() ([]byte, []int)

Deprecated: Use DescribeActivityResponse.ProtoReflect.Descriptor instead.

func (*DescribeActivityResponse) GetData 

func (x *DescribeActivityResponse) GetData() *ActivityInfo

func (*DescribeActivityResponse) ProtoMessage 

func (*DescribeActivityResponse) ProtoMessage()

func (*DescribeActivityResponse) ProtoReflect 

func (x *DescribeActivityResponse) ProtoReflect() protoreflect.Message

func (*DescribeActivityResponse) Reset 

func (x *DescribeActivityResponse) Reset()

func (*DescribeActivityResponse) String 

func (x *DescribeActivityResponse) String() string

type DescribeExecutionBoneRequest 

type DescribeExecutionBoneRequest struct {

	// execution uuid 必选
	ExecutionUuid string `protobuf:"bytes,1,opt,name=execution_uuid,json=executionUuid,proto3" json:"execution_uuid,omitempty"`
	// pipeline_mode 是否是pipeline模式， 可选，默认是false
	PipelineMode bool `protobuf:"varint,2,opt,name=pipeline_mode,json=pipelineMode,proto3" json:"pipeline_mode,omitempty"`
	// contains filtered or unexported fields
}

获得一个执行的执行的Bone请求结构

func (*DescribeExecutionBoneRequest) Descriptor deprecated 

func (*DescribeExecutionBoneRequest) Descriptor() ([]byte, []int)

Deprecated: Use DescribeExecutionBoneRequest.ProtoReflect.Descriptor instead.

func (*DescribeExecutionBoneRequest) GetExecutionUuid 

func (x *DescribeExecutionBoneRequest) GetExecutionUuid() string

func (*DescribeExecutionBoneRequest) GetPipelineMode 

func (x *DescribeExecutionBoneRequest) GetPipelineMode() bool

func (*DescribeExecutionBoneRequest) ProtoMessage 

func (*DescribeExecutionBoneRequest) ProtoMessage()

func (*DescribeExecutionBoneRequest) ProtoReflect 

func (x *DescribeExecutionBoneRequest) ProtoReflect() protoreflect.Message

func (*DescribeExecutionBoneRequest) Reset 

func (x *DescribeExecutionBoneRequest) Reset()

func (*DescribeExecutionBoneRequest) String 

func (x *DescribeExecutionBoneRequest) String() string

type DescribeExecutionBoneResponse 

type DescribeExecutionBoneResponse struct {
	Execution *ExecutionInfo `protobuf:"bytes,1,opt,name=execution,proto3" json:"execution,omitempty"`
	Bone      string         `protobuf:"bytes,2,opt,name=bone,proto3" json:"bone,omitempty"`
	// contains filtered or unexported fields
}

获得一个执行的描述d的返回结构

func (*DescribeExecutionBoneResponse) Descriptor deprecated 

func (*DescribeExecutionBoneResponse) Descriptor() ([]byte, []int)

Deprecated: Use DescribeExecutionBoneResponse.ProtoReflect.Descriptor instead.

func (*DescribeExecutionBoneResponse) GetBone 

func (x *DescribeExecutionBoneResponse) GetBone() string

func (*DescribeExecutionBoneResponse) GetExecution 

func (x *DescribeExecutionBoneResponse) GetExecution() *ExecutionInfo

func (*DescribeExecutionBoneResponse) ProtoMessage 

func (*DescribeExecutionBoneResponse) ProtoMessage()

func (*DescribeExecutionBoneResponse) ProtoReflect 

func (x *DescribeExecutionBoneResponse) ProtoReflect() protoreflect.Message

func (*DescribeExecutionBoneResponse) Reset 

func (x *DescribeExecutionBoneResponse) Reset()

func (*DescribeExecutionBoneResponse) String 

func (x *DescribeExecutionBoneResponse) String() string

type DescribeExecutionRequest 

type DescribeExecutionRequest struct {

	// execution uuid 必选
	ExecutionUuid string `protobuf:"bytes,1,opt,name=execution_uuid,json=executionUuid,proto3" json:"execution_uuid,omitempty"`
	// contains filtered or unexported fields
}

获得一个执行的描述请求结构

func (*DescribeExecutionRequest) Descriptor deprecated 

func (*DescribeExecutionRequest) Descriptor() ([]byte, []int)

Deprecated: Use DescribeExecutionRequest.ProtoReflect.Descriptor instead.

func (*DescribeExecutionRequest) GetExecutionUuid 

func (x *DescribeExecutionRequest) GetExecutionUuid() string

func (*DescribeExecutionRequest) ProtoMessage 

func (*DescribeExecutionRequest) ProtoMessage()

func (*DescribeExecutionRequest) ProtoReflect 

func (x *DescribeExecutionRequest) ProtoReflect() protoreflect.Message

func (*DescribeExecutionRequest) Reset 

func (x *DescribeExecutionRequest) Reset()

func (*DescribeExecutionRequest) String 

func (x *DescribeExecutionRequest) String() string

type DescribeExecutionResponse 

type DescribeExecutionResponse struct {
	Execution *ExecutionInfo `protobuf:"bytes,1,opt,name=execution,proto3" json:"execution,omitempty"`
	// contains filtered or unexported fields
}

获得一个执行的描述d的返回结构

func (*DescribeExecutionResponse) Descriptor deprecated 

func (*DescribeExecutionResponse) Descriptor() ([]byte, []int)

Deprecated: Use DescribeExecutionResponse.ProtoReflect.Descriptor instead.

func (*DescribeExecutionResponse) GetExecution 

func (x *DescribeExecutionResponse) GetExecution() *ExecutionInfo

func (*DescribeExecutionResponse) ProtoMessage 

func (*DescribeExecutionResponse) ProtoMessage()

func (*DescribeExecutionResponse) ProtoReflect 

func (x *DescribeExecutionResponse) ProtoReflect() protoreflect.Message

func (*DescribeExecutionResponse) Reset 

func (x *DescribeExecutionResponse) Reset()

func (*DescribeExecutionResponse) String 

func (x *DescribeExecutionResponse) String() string

type DescribeStepRequest 

type DescribeStepRequest struct {

	// step id
	StepId int64 `protobuf:"varint,1,opt,name=step_id,json=stepId,proto3" json:"step_id,omitempty"`
	// contains filtered or unexported fields
}

DescribeStepRequest 获得一个step的信息请求结构

func (*DescribeStepRequest) Descriptor deprecated 

func (*DescribeStepRequest) Descriptor() ([]byte, []int)

Deprecated: Use DescribeStepRequest.ProtoReflect.Descriptor instead.

func (*DescribeStepRequest) GetStepId 

func (x *DescribeStepRequest) GetStepId() int64

func (*DescribeStepRequest) ProtoMessage 

func (*DescribeStepRequest) ProtoMessage()

func (*DescribeStepRequest) ProtoReflect 

func (x *DescribeStepRequest) ProtoReflect() protoreflect.Message

func (*DescribeStepRequest) Reset 

func (x *DescribeStepRequest) Reset()

func (*DescribeStepRequest) String 

func (x *DescribeStepRequest) String() string

type DescribeStepResponse 

type DescribeStepResponse struct {

	// 返回的step 状态信息
	Data *StepInfo `protobuf:"bytes,1,opt,name=data,proto3" json:"data,omitempty"`
	// execution uuid
	ExecutionUuid string `protobuf:"bytes,2,opt,name=execution_uuid,json=executionUuid,proto3" json:"execution_uuid,omitempty"`
	// contains filtered or unexported fields
}

DescribeStepRequest 获得一个step的信息返回结构

func (*DescribeStepResponse) Descriptor deprecated 

func (*DescribeStepResponse) Descriptor() ([]byte, []int)

Deprecated: Use DescribeStepResponse.ProtoReflect.Descriptor instead.

func (*DescribeStepResponse) GetData 

func (x *DescribeStepResponse) GetData() *StepInfo

func (*DescribeStepResponse) GetExecutionUuid 

func (x *DescribeStepResponse) GetExecutionUuid() string

func (*DescribeStepResponse) ProtoMessage 

func (*DescribeStepResponse) ProtoMessage()

func (*DescribeStepResponse) ProtoReflect 

func (x *DescribeStepResponse) ProtoReflect() protoreflect.Message

func (*DescribeStepResponse) Reset 

func (x *DescribeStepResponse) Reset()

func (*DescribeStepResponse) String 

func (x *DescribeStepResponse) String() string

type DescribeWorkflowRequest 

type DescribeWorkflowRequest struct {
	WorkflowUri string `protobuf:"bytes,1,opt,name=workflow_uri,json=workflowUri,proto3" json:"workflow_uri,omitempty"`
	// contains filtered or unexported fields
}

DescribeActivityRequest 获得工作流详情返回结构

func (*DescribeWorkflowRequest) Descriptor deprecated 

func (*DescribeWorkflowRequest) Descriptor() ([]byte, []int)

Deprecated: Use DescribeWorkflowRequest.ProtoReflect.Descriptor instead.

func (*DescribeWorkflowRequest) GetWorkflowUri 

func (x *DescribeWorkflowRequest) GetWorkflowUri() string

func (*DescribeWorkflowRequest) ProtoMessage 

func (*DescribeWorkflowRequest) ProtoMessage()

func (*DescribeWorkflowRequest) ProtoReflect 

func (x *DescribeWorkflowRequest) ProtoReflect() protoreflect.Message

func (*DescribeWorkflowRequest) Reset 

func (x *DescribeWorkflowRequest) Reset()

func (*DescribeWorkflowRequest) String 

func (x *DescribeWorkflowRequest) String() string

type DescribeWorkflowResponse 

type DescribeWorkflowResponse struct {
	Data *WorkflowInfo `protobuf:"bytes,1,opt,name=data,proto3" json:"data,omitempty"`
	// contains filtered or unexported fields
}

DescribeWorkflowResponse 获得活动列表请求返回结构

func (*DescribeWorkflowResponse) Descriptor deprecated 

func (*DescribeWorkflowResponse) Descriptor() ([]byte, []int)

Deprecated: Use DescribeWorkflowResponse.ProtoReflect.Descriptor instead.

func (*DescribeWorkflowResponse) GetData 

func (x *DescribeWorkflowResponse) GetData() *WorkflowInfo

func (*DescribeWorkflowResponse) ProtoMessage 

func (*DescribeWorkflowResponse) ProtoMessage()

func (*DescribeWorkflowResponse) ProtoReflect 

func (x *DescribeWorkflowResponse) ProtoReflect() protoreflect.Message

func (*DescribeWorkflowResponse) Reset 

func (x *DescribeWorkflowResponse) Reset()

func (*DescribeWorkflowResponse) String 

func (x *DescribeWorkflowResponse) String() string

type ErrorCode 

type ErrorCode int32

ErrorCode 错误码定义 

const (
	// 正常
	ErrorCode_OK ErrorCode = 0
	// 未知错误
	ErrorCode_UnknownError ErrorCode = 1000
	// 内部错误
	ErrorCode_InternelError ErrorCode = 1001
	// execution 不存在
	ErrorCode_ExecutionNotFound ErrorCode = 1002
	// step 不存在
	ErrorCode_StepNotFound ErrorCode = 1003
	// stepgroup 不存在
	ErrorCode_StepGroupNotFound ErrorCode = 1004
	// TaskToken 不存在
	ErrorCode_TaskTokenNotFound ErrorCode = 1005
	// namespace 不存在
	ErrorCode_NamespaceNotFound ErrorCode = 1006
	// activity 不存在
	ErrorCode_ActivityNotFound ErrorCode = 1007
	// workflow 不存在
	ErrorCode_WorkflowNotFound ErrorCode = 1008
	// Execution UUID 已经存在
	ErrorCode_ExecutionUUIDExisted ErrorCode = 1009
	// activity  task 不存在
	ErrorCode_ActivityTaskNotFound ErrorCode = 1010
	// step 状态错误
	ErrorCode_StepStatusError ErrorCode = 1011
	// execution 状态错误
	ErrorCode_ExecutionStatusError ErrorCode = 1012
	// parameter is vaild
	ErrorCode_ParameterIsVaild ErrorCode = 1013
	// parameter limit exceeded
	ErrorCode_ParameterLimitExceeded ErrorCode = 1014
	// input limit exceeded
	ErrorCode_InputLimitExceeded ErrorCode = 1015
	// output limit exceed
	ErrorCode_OutputLimitExceeded ErrorCode = 1016
	// workflow definition invalid
	ErrorCode_WorkflowDeinitionInvalid ErrorCode = 1017
	// ResourceLimitExceeded 资源限制超出
	ErrorCode_ResourceLimitExceeded ErrorCode = 2000
)

func (ErrorCode) Descriptor 

func (ErrorCode) Descriptor() protoreflect.EnumDescriptor

func (ErrorCode) Enum 

func (x ErrorCode) Enum() *ErrorCode

func (ErrorCode) EnumDescriptor deprecated 

func (ErrorCode) EnumDescriptor() ([]byte, []int)

Deprecated: Use ErrorCode.Descriptor instead.

func (ErrorCode) Number 

func (x ErrorCode) Number() protoreflect.EnumNumber

func (ErrorCode) String 

func (x ErrorCode) String() string

func (ErrorCode) Type 

func (ErrorCode) Type() protoreflect.EnumType

type ExecutionEventInfo 

type ExecutionEventInfo struct {
	StepId     int64  `protobuf:"varint,2,opt,name=step_id,json=stepId,proto3" json:"step_id,omitempty"`
	StepName   string `protobuf:"bytes,3,opt,name=step_name,json=stepName,proto3" json:"step_name,omitempty"`
	EventType  string `protobuf:"bytes,4,opt,name=event_type,json=eventType,proto3" json:"event_type,omitempty"`
	Data       string `protobuf:"bytes,5,opt,name=data,proto3" json:"data,omitempty"`
	CreateTime string `protobuf:"bytes,11,opt,name=create_time,json=createTime,proto3" json:"create_time,omitempty"`
	StartTime  string `protobuf:"bytes,12,opt,name=start_time,json=startTime,proto3" json:"start_time,omitempty"`
	FinishTime string `protobuf:"bytes,13,opt,name=finish_time,json=finishTime,proto3" json:"finish_time,omitempty"`
	// contains filtered or unexported fields
}

ExecutionEventInfo 执行事件

func (*ExecutionEventInfo) Descriptor deprecated 

func (*ExecutionEventInfo) Descriptor() ([]byte, []int)

Deprecated: Use ExecutionEventInfo.ProtoReflect.Descriptor instead.

func (*ExecutionEventInfo) GetCreateTime 

func (x *ExecutionEventInfo) GetCreateTime() string

func (*ExecutionEventInfo) GetData 

func (x *ExecutionEventInfo) GetData() string

func (*ExecutionEventInfo) GetEventType 

func (x *ExecutionEventInfo) GetEventType() string

func (*ExecutionEventInfo) GetFinishTime 

func (x *ExecutionEventInfo) GetFinishTime() string

func (*ExecutionEventInfo) GetStartTime 

func (x *ExecutionEventInfo) GetStartTime() string

func (*ExecutionEventInfo) GetStepId 

func (x *ExecutionEventInfo) GetStepId() int64

func (*ExecutionEventInfo) GetStepName 

func (x *ExecutionEventInfo) GetStepName() string

func (*ExecutionEventInfo) ProtoMessage 

func (*ExecutionEventInfo) ProtoMessage()

func (*ExecutionEventInfo) ProtoReflect 

func (x *ExecutionEventInfo) ProtoReflect() protoreflect.Message

func (*ExecutionEventInfo) Reset 

func (x *ExecutionEventInfo) Reset()

func (*ExecutionEventInfo) String 

func (x *ExecutionEventInfo) String() string

type ExecutionInfo 

type ExecutionInfo struct {
	ExecutionUuid      string `protobuf:"bytes,1,opt,name=execution_uuid,json=executionUuid,proto3" json:"execution_uuid,omitempty"`
	Status             string `protobuf:"bytes,2,opt,name=status,proto3" json:"status,omitempty"`
	Title              string `protobuf:"bytes,3,opt,name=title,proto3" json:"title,omitempty"`
	WorkflowDefinition string `protobuf:"bytes,4,opt,name=workflow_definition,json=workflowDefinition,proto3" json:"workflow_definition,omitempty"`
	Input              string `protobuf:"bytes,5,opt,name=input,proto3" json:"input,omitempty"`
	Output             string `protobuf:"bytes,6,opt,name=output,proto3" json:"output,omitempty"`
	FlowType           string `protobuf:"bytes,7,opt,name=flow_type,json=flowType,proto3" json:"flow_type,omitempty"`
	CreateTime         string `protobuf:"bytes,11,opt,name=create_time,json=createTime,proto3" json:"create_time,omitempty"`
	StartTime          string `protobuf:"bytes,12,opt,name=start_time,json=startTime,proto3" json:"start_time,omitempty"`
	FinishTime         string `protobuf:"bytes,13,opt,name=finish_time,json=finishTime,proto3" json:"finish_time,omitempty"`
	// contains filtered or unexported fields
}

ExecutionInfo 一个Execution 的描述

func (*ExecutionInfo) Descriptor deprecated 

func (*ExecutionInfo) Descriptor() ([]byte, []int)

Deprecated: Use ExecutionInfo.ProtoReflect.Descriptor instead.

func (*ExecutionInfo) GetCreateTime 

func (x *ExecutionInfo) GetCreateTime() string

func (*ExecutionInfo) GetExecutionUuid 

func (x *ExecutionInfo) GetExecutionUuid() string

func (*ExecutionInfo) GetFinishTime 

func (x *ExecutionInfo) GetFinishTime() string

func (*ExecutionInfo) GetFlowType 

func (x *ExecutionInfo) GetFlowType() string

func (*ExecutionInfo) GetInput 

func (x *ExecutionInfo) GetInput() string

func (*ExecutionInfo) GetOutput 

func (x *ExecutionInfo) GetOutput() string

func (*ExecutionInfo) GetStartTime 

func (x *ExecutionInfo) GetStartTime() string

func (*ExecutionInfo) GetStatus 

func (x *ExecutionInfo) GetStatus() string

func (*ExecutionInfo) GetTitle 

func (x *ExecutionInfo) GetTitle() string

func (*ExecutionInfo) GetWorkflowDefinition 

func (x *ExecutionInfo) GetWorkflowDefinition() string

func (*ExecutionInfo) ProtoMessage 

func (*ExecutionInfo) ProtoMessage()

func (*ExecutionInfo) ProtoReflect 

func (x *ExecutionInfo) ProtoReflect() protoreflect.Message

func (*ExecutionInfo) Reset 

func (x *ExecutionInfo) Reset()

func (*ExecutionInfo) String 

func (x *ExecutionInfo) String() string

type GetActivityTaskRequest 

type GetActivityTaskRequest struct {

	// task uri
	ActivityUri string `protobuf:"bytes,1,opt,name=activity_uri,json=activityUri,proto3" json:"activity_uri,omitempty"`
	// contains filtered or unexported fields
}

GetActivityTaskRequest 通过URI查询是否有一个需要执行的task

func (*GetActivityTaskRequest) Descriptor deprecated 

func (*GetActivityTaskRequest) Descriptor() ([]byte, []int)

Deprecated: Use GetActivityTaskRequest.ProtoReflect.Descriptor instead.

func (*GetActivityTaskRequest) GetActivityUri 

func (x *GetActivityTaskRequest) GetActivityUri() string

func (*GetActivityTaskRequest) ProtoMessage 

func (*GetActivityTaskRequest) ProtoMessage()

func (*GetActivityTaskRequest) ProtoReflect 

func (x *GetActivityTaskRequest) ProtoReflect() protoreflect.Message

func (*GetActivityTaskRequest) Reset 

func (x *GetActivityTaskRequest) Reset()

func (*GetActivityTaskRequest) String 

func (x *GetActivityTaskRequest) String() string

type GetActivityTaskResponse 

type GetActivityTaskResponse struct {

	// task_uri
	ActivityUri string `protobuf:"bytes,1,opt,name=activity_uri,json=activityUri,proto3" json:"activity_uri,omitempty"`
	// task_token
	TaskToken string `protobuf:"bytes,2,opt,name=task_token,json=taskToken,proto3" json:"task_token,omitempty"`
	// task 的输入，需要worker自己解码
	Input string `protobuf:"bytes,3,opt,name=input,proto3" json:"input,omitempty"`
	// Deprecated: 该字段已经废弃，使用timeout_seconds
	// task 的超时时间，单位(s), 0表示不超时
	TimeoutSecond int64 `protobuf:"varint,4,opt,name=timeout_second,json=timeoutSecond,proto3" json:"timeout_second,omitempty"`
	// Deprecated: 该字段已经废弃，使用heartbeat_seconds
	// task 心跳超时时间，单位(s), 0 表示不超时
	HeartbeatTimeoutSecond int64 `` /* 130-byte string literal not displayed */
	// task 的超时时间，单位(s), 0表示不超时
	TimeoutSeconds int64 `protobuf:"varint,6,opt,name=timeout_seconds,json=timeoutSeconds,proto3" json:"timeout_seconds,omitempty"`
	// task 心跳超时时间，单位(s), 0 表示不超时
	HeartbeatSeconds int64 `protobuf:"varint,7,opt,name=heartbeat_seconds,json=heartbeatSeconds,proto3" json:"heartbeat_seconds,omitempty"`
	// task 的额外信息
	ExtraInfo *GetActivityTaskResponse_ExtraInfo `protobuf:"bytes,10,opt,name=extra_info,json=extraInfo,proto3" json:"extra_info,omitempty"`
	// contains filtered or unexported fields
}

GetActivityTaskResponse 返回查询到的结构

func (*GetActivityTaskResponse) Descriptor deprecated 

func (*GetActivityTaskResponse) Descriptor() ([]byte, []int)

Deprecated: Use GetActivityTaskResponse.ProtoReflect.Descriptor instead.

func (*GetActivityTaskResponse) GetActivityUri 

func (x *GetActivityTaskResponse) GetActivityUri() string

func (*GetActivityTaskResponse) GetExtraInfo 

func (x *GetActivityTaskResponse) GetExtraInfo() *GetActivityTaskResponse_ExtraInfo

func (*GetActivityTaskResponse) GetHeartbeatSeconds 

func (x *GetActivityTaskResponse) GetHeartbeatSeconds() int64

func (*GetActivityTaskResponse) GetHeartbeatTimeoutSecond 

func (x *GetActivityTaskResponse) GetHeartbeatTimeoutSecond() int64

func (*GetActivityTaskResponse) GetInput 

func (x *GetActivityTaskResponse) GetInput() string

func (*GetActivityTaskResponse) GetTaskToken 

func (x *GetActivityTaskResponse) GetTaskToken() string

func (*GetActivityTaskResponse) GetTimeoutSecond 

func (x *GetActivityTaskResponse) GetTimeoutSecond() int64

func (*GetActivityTaskResponse) GetTimeoutSeconds 

func (x *GetActivityTaskResponse) GetTimeoutSeconds() int64

func (*GetActivityTaskResponse) ProtoMessage 

func (*GetActivityTaskResponse) ProtoMessage()

func (*GetActivityTaskResponse) ProtoReflect 

func (x *GetActivityTaskResponse) ProtoReflect() protoreflect.Message

func (*GetActivityTaskResponse) Reset 

func (x *GetActivityTaskResponse) Reset()

func (*GetActivityTaskResponse) String 

func (x *GetActivityTaskResponse) String() string

type GetActivityTaskResponse_ExtraInfo 

type GetActivityTaskResponse_ExtraInfo struct {

	// step id
	StepId int64 `protobuf:"varint,1,opt,name=step_id,json=stepId,proto3" json:"step_id,omitempty"`
	// execution uuid
	ExecutionUuid string `protobuf:"bytes,2,opt,name=execution_uuid,json=executionUuid,proto3" json:"execution_uuid,omitempty"`
	// contains filtered or unexported fields
}

func (*GetActivityTaskResponse_ExtraInfo) Descriptor deprecated 

func (*GetActivityTaskResponse_ExtraInfo) Descriptor() ([]byte, []int)

Deprecated: Use GetActivityTaskResponse_ExtraInfo.ProtoReflect.Descriptor instead.

func (*GetActivityTaskResponse_ExtraInfo) GetExecutionUuid 

func (x *GetActivityTaskResponse_ExtraInfo) GetExecutionUuid() string

func (*GetActivityTaskResponse_ExtraInfo) GetStepId 

func (x *GetActivityTaskResponse_ExtraInfo) GetStepId() int64

func (*GetActivityTaskResponse_ExtraInfo) ProtoMessage 

func (*GetActivityTaskResponse_ExtraInfo) ProtoMessage()

func (*GetActivityTaskResponse_ExtraInfo) ProtoReflect 

func (x *GetActivityTaskResponse_ExtraInfo) ProtoReflect() protoreflect.Message

func (*GetActivityTaskResponse_ExtraInfo) Reset 

func (x *GetActivityTaskResponse_ExtraInfo) Reset()

func (*GetActivityTaskResponse_ExtraInfo) String 

func (x *GetActivityTaskResponse_ExtraInfo) String() string

type HTTPResponseMessage 

type HTTPResponseMessage struct {

	// 返回码，0为正常，非0为异常
	Retcode int32 `protobuf:"varint,1,opt,name=retcode,proto3" json:"retcode,omitempty"`
	// 异常信息说明
	Message string `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"`
	// contains filtered or unexported fields
}

func (*HTTPResponseMessage) Descriptor deprecated 

func (*HTTPResponseMessage) Descriptor() ([]byte, []int)

Deprecated: Use HTTPResponseMessage.ProtoReflect.Descriptor instead.

func (*HTTPResponseMessage) GetMessage 

func (x *HTTPResponseMessage) GetMessage() string

func (*HTTPResponseMessage) GetRetcode 

func (x *HTTPResponseMessage) GetRetcode() int32

func (*HTTPResponseMessage) ProtoMessage 

func (*HTTPResponseMessage) ProtoMessage()

func (*HTTPResponseMessage) ProtoReflect 

func (x *HTTPResponseMessage) ProtoReflect() protoreflect.Message

func (*HTTPResponseMessage) Reset 

func (x *HTTPResponseMessage) Reset()

func (*HTTPResponseMessage) String 

func (x *HTTPResponseMessage) String() string

type ListActivitiesRequest 

type ListActivitiesRequest struct {
	Namespace string `protobuf:"bytes,1,opt,name=namespace,proto3" json:"namespace,omitempty"`
	// 分页请求，默认 每分页大小 = 50条
	PageRequest *PageRequest `protobuf:"bytes,2,opt,name=page_request,json=pageRequest,proto3" json:"page_request,omitempty"`
	// contains filtered or unexported fields
}

ListActivitiesRequest 获得活动列表请求结构

func (*ListActivitiesRequest) Descriptor deprecated 

func (*ListActivitiesRequest) Descriptor() ([]byte, []int)

Deprecated: Use ListActivitiesRequest.ProtoReflect.Descriptor instead.

func (*ListActivitiesRequest) GetNamespace 

func (x *ListActivitiesRequest) GetNamespace() string

func (*ListActivitiesRequest) GetPageRequest 

func (x *ListActivitiesRequest) GetPageRequest() *PageRequest

func (*ListActivitiesRequest) ProtoMessage 

func (*ListActivitiesRequest) ProtoMessage()

func (*ListActivitiesRequest) ProtoReflect 

func (x *ListActivitiesRequest) ProtoReflect() protoreflect.Message

func (*ListActivitiesRequest) Reset 

func (x *ListActivitiesRequest) Reset()

func (*ListActivitiesRequest) String 

func (x *ListActivitiesRequest) String() string

type ListActivitiesResponse 

type ListActivitiesResponse struct {

	// 查询到的执行列表
	Data []*ActivityInfo `protobuf:"bytes,1,rep,name=data,proto3" json:"data,omitempty"`
	// 分页信息
	PageResponse *PageResponse `protobuf:"bytes,2,opt,name=page_response,json=pageResponse,proto3" json:"page_response,omitempty"`
	// contains filtered or unexported fields
}

ListActivitiesResponse 获得活动列表请求返回

func (*ListActivitiesResponse) Descriptor deprecated 

func (*ListActivitiesResponse) Descriptor() ([]byte, []int)

Deprecated: Use ListActivitiesResponse.ProtoReflect.Descriptor instead.

func (*ListActivitiesResponse) GetData 

func (x *ListActivitiesResponse) GetData() []*ActivityInfo

func (*ListActivitiesResponse) GetPageResponse 

func (x *ListActivitiesResponse) GetPageResponse() *PageResponse

func (*ListActivitiesResponse) ProtoMessage 

func (*ListActivitiesResponse) ProtoMessage()

func (*ListActivitiesResponse) ProtoReflect 

func (x *ListActivitiesResponse) ProtoReflect() protoreflect.Message

func (*ListActivitiesResponse) Reset 

func (x *ListActivitiesResponse) Reset()

func (*ListActivitiesResponse) String 

func (x *ListActivitiesResponse) String() string

type ListExecutionEventsRequest 

type ListExecutionEventsRequest struct {
	ExecutionUuid string       `protobuf:"bytes,1,opt,name=execution_uuid,json=executionUuid,proto3" json:"execution_uuid,omitempty"`
	PageRequest   *PageRequest `protobuf:"bytes,2,opt,name=page_request,json=pageRequest,proto3" json:"page_request,omitempty"`
	// contains filtered or unexported fields
}

ListExecutionEventsRequest  获得一个执行的Event列表请求结构

func (*ListExecutionEventsRequest) Descriptor deprecated 

func (*ListExecutionEventsRequest) Descriptor() ([]byte, []int)

Deprecated: Use ListExecutionEventsRequest.ProtoReflect.Descriptor instead.

func (*ListExecutionEventsRequest) GetExecutionUuid 

func (x *ListExecutionEventsRequest) GetExecutionUuid() string

func (*ListExecutionEventsRequest) GetPageRequest 

func (x *ListExecutionEventsRequest) GetPageRequest() *PageRequest

func (*ListExecutionEventsRequest) ProtoMessage 

func (*ListExecutionEventsRequest) ProtoMessage()

func (*ListExecutionEventsRequest) ProtoReflect 

func (x *ListExecutionEventsRequest) ProtoReflect() protoreflect.Message

func (*ListExecutionEventsRequest) Reset 

func (x *ListExecutionEventsRequest) Reset()

func (*ListExecutionEventsRequest) String 

func (x *ListExecutionEventsRequest) String() string

type ListExecutionEventsResponse 

type ListExecutionEventsResponse struct {

	// 返回Event列表
	Data []*ExecutionEventInfo `protobuf:"bytes,1,rep,name=data,proto3" json:"data,omitempty"`
	// 分页信息
	PageResponse *PageResponse `protobuf:"bytes,2,opt,name=page_response,json=pageResponse,proto3" json:"page_response,omitempty"`
	// contains filtered or unexported fields
}

ListExecutionEventsResponse 获得一个执行的Event列表返回值

func (*ListExecutionEventsResponse) Descriptor deprecated 

func (*ListExecutionEventsResponse) Descriptor() ([]byte, []int)

Deprecated: Use ListExecutionEventsResponse.ProtoReflect.Descriptor instead.

func (*ListExecutionEventsResponse) GetData 

func (x *ListExecutionEventsResponse) GetData() []*ExecutionEventInfo

func (*ListExecutionEventsResponse) GetPageResponse 

func (x *ListExecutionEventsResponse) GetPageResponse() *PageResponse

func (*ListExecutionEventsResponse) ProtoMessage 

func (*ListExecutionEventsResponse) ProtoMessage()

func (*ListExecutionEventsResponse) ProtoReflect 

func (x *ListExecutionEventsResponse) ProtoReflect() protoreflect.Message

func (*ListExecutionEventsResponse) Reset 

func (x *ListExecutionEventsResponse) Reset()

func (*ListExecutionEventsResponse) String 

func (x *ListExecutionEventsResponse) String() string

type ListExecutionsRequest 

type ListExecutionsRequest struct {

	// 流程名字, 按照名字查询， 可选
	WorkflowUri string `protobuf:"bytes,1,opt,name=workflow_uri,json=workflowUri,proto3" json:"workflow_uri,omitempty"`
	// uuid 列表，指定的uuid列表查询， 可选, 最大100个
	ExecutionUuids []string `protobuf:"bytes,2,rep,name=execution_uuids,json=executionUuids,proto3" json:"execution_uuids,omitempty"`
	// 状态，按照状态查询， 可选
	Status string `protobuf:"bytes,3,opt,name=status,proto3" json:"status,omitempty"`
	// title按照title 关键字查询，可选。title like "%${title}%"
	Title string `protobuf:"bytes,4,opt,name=title,proto3" json:"title,omitempty"`
	// 分页请求，默认 每分页大小 = 50条
	PageRequest *PageRequest `protobuf:"bytes,10,opt,name=page_request,json=pageRequest,proto3" json:"page_request,omitempty"`
	// contains filtered or unexported fields
}

ListExecutionsRequest 获得execution列表请求结构

func (*ListExecutionsRequest) Descriptor deprecated 

func (*ListExecutionsRequest) Descriptor() ([]byte, []int)

Deprecated: Use ListExecutionsRequest.ProtoReflect.Descriptor instead.

func (*ListExecutionsRequest) GetExecutionUuids 

func (x *ListExecutionsRequest) GetExecutionUuids() []string

func (*ListExecutionsRequest) GetPageRequest 

func (x *ListExecutionsRequest) GetPageRequest() *PageRequest

func (*ListExecutionsRequest) GetStatus 

func (x *ListExecutionsRequest) GetStatus() string

func (*ListExecutionsRequest) GetTitle 

func (x *ListExecutionsRequest) GetTitle() string

func (*ListExecutionsRequest) GetWorkflowUri 

func (x *ListExecutionsRequest) GetWorkflowUri() string

func (*ListExecutionsRequest) ProtoMessage 

func (*ListExecutionsRequest) ProtoMessage()

func (*ListExecutionsRequest) ProtoReflect 

func (x *ListExecutionsRequest) ProtoReflect() protoreflect.Message

func (*ListExecutionsRequest) Reset 

func (x *ListExecutionsRequest) Reset()

func (*ListExecutionsRequest) String 

func (x *ListExecutionsRequest) String() string

type ListExecutionsResponse 

type ListExecutionsResponse struct {

	// 查询到的执行列表
	Data []*ExecutionInfo `protobuf:"bytes,1,rep,name=data,proto3" json:"data,omitempty"`
	// 分页信息
	PageResponse *PageResponse `protobuf:"bytes,2,opt,name=page_response,json=pageResponse,proto3" json:"page_response,omitempty"`
	// contains filtered or unexported fields
}

ListExecutionsResponse 获得execution列表返回值

func (*ListExecutionsResponse) Descriptor deprecated 

func (*ListExecutionsResponse) Descriptor() ([]byte, []int)

Deprecated: Use ListExecutionsResponse.ProtoReflect.Descriptor instead.

func (*ListExecutionsResponse) GetData 

func (x *ListExecutionsResponse) GetData() []*ExecutionInfo

func (*ListExecutionsResponse) GetPageResponse 

func (x *ListExecutionsResponse) GetPageResponse() *PageResponse

func (*ListExecutionsResponse) ProtoMessage 

func (*ListExecutionsResponse) ProtoMessage()

func (*ListExecutionsResponse) ProtoReflect 

func (x *ListExecutionsResponse) ProtoReflect() protoreflect.Message

func (*ListExecutionsResponse) Reset 

func (x *ListExecutionsResponse) Reset()

func (*ListExecutionsResponse) String 

func (x *ListExecutionsResponse) String() string

type ListNamespacesRequest 

type ListNamespacesRequest struct {

	// 分页请求，默认 每分页大小 = 50条
	PageRequest *PageRequest `protobuf:"bytes,1,opt,name=page_request,json=pageRequest,proto3" json:"page_request,omitempty"`
	// contains filtered or unexported fields
}

ListNamespacesRequest 获得命名空间列表

func (*ListNamespacesRequest) Descriptor deprecated 

func (*ListNamespacesRequest) Descriptor() ([]byte, []int)

Deprecated: Use ListNamespacesRequest.ProtoReflect.Descriptor instead.

func (*ListNamespacesRequest) GetPageRequest 

func (x *ListNamespacesRequest) GetPageRequest() *PageRequest

func (*ListNamespacesRequest) ProtoMessage 

func (*ListNamespacesRequest) ProtoMessage()

func (*ListNamespacesRequest) ProtoReflect 

func (x *ListNamespacesRequest) ProtoReflect() protoreflect.Message

func (*ListNamespacesRequest) Reset 

func (x *ListNamespacesRequest) Reset()

func (*ListNamespacesRequest) String 

func (x *ListNamespacesRequest) String() string

type ListNamespacesResponse 

type ListNamespacesResponse struct {

	// 查询到的执行列表
	Data []*NamespaceInfo `protobuf:"bytes,1,rep,name=data,proto3" json:"data,omitempty"`
	// 分页信息
	PageResponse *PageResponse `protobuf:"bytes,2,opt,name=page_response,json=pageResponse,proto3" json:"page_response,omitempty"`
	// contains filtered or unexported fields
}

func (*ListNamespacesResponse) Descriptor deprecated 

func (*ListNamespacesResponse) Descriptor() ([]byte, []int)

Deprecated: Use ListNamespacesResponse.ProtoReflect.Descriptor instead.

func (*ListNamespacesResponse) GetData 

func (x *ListNamespacesResponse) GetData() []*NamespaceInfo

func (*ListNamespacesResponse) GetPageResponse 

func (x *ListNamespacesResponse) GetPageResponse() *PageResponse

func (*ListNamespacesResponse) ProtoMessage 

func (*ListNamespacesResponse) ProtoMessage()

func (*ListNamespacesResponse) ProtoReflect 

func (x *ListNamespacesResponse) ProtoReflect() protoreflect.Message

func (*ListNamespacesResponse) Reset 

func (x *ListNamespacesResponse) Reset()

func (*ListNamespacesResponse) String 

func (x *ListNamespacesResponse) String() string

type ListStepEventsRequest 

type ListStepEventsRequest struct {

	// step id
	StepId int64 `protobuf:"varint,1,opt,name=step_id,json=stepId,proto3" json:"step_id,omitempty"`
	// 分页信息
	PageRequest *PageRequest `protobuf:"bytes,2,opt,name=page_request,json=pageRequest,proto3" json:"page_request,omitempty"`
	// contains filtered or unexported fields
}

ListStepEventsRequest 获得一个step的执行事件列表请求机构

func (*ListStepEventsRequest) Descriptor deprecated 

func (*ListStepEventsRequest) Descriptor() ([]byte, []int)

Deprecated: Use ListStepEventsRequest.ProtoReflect.Descriptor instead.

func (*ListStepEventsRequest) GetPageRequest 

func (x *ListStepEventsRequest) GetPageRequest() *PageRequest

func (*ListStepEventsRequest) GetStepId 

func (x *ListStepEventsRequest) GetStepId() int64

func (*ListStepEventsRequest) ProtoMessage 

func (*ListStepEventsRequest) ProtoMessage()

func (*ListStepEventsRequest) ProtoReflect 

func (x *ListStepEventsRequest) ProtoReflect() protoreflect.Message

func (*ListStepEventsRequest) Reset 

func (x *ListStepEventsRequest) Reset()

func (*ListStepEventsRequest) String 

func (x *ListStepEventsRequest) String() string

type ListWorkflowsRequest 

type ListWorkflowsRequest struct {
	Namespace string `protobuf:"bytes,1,opt,name=namespace,proto3" json:"namespace,omitempty"`
	// 分页请求，默认 每分页大小 = 50条
	PageRequest *PageRequest `protobuf:"bytes,2,opt,name=page_request,json=pageRequest,proto3" json:"page_request,omitempty"`
	// contains filtered or unexported fields
}

ListWorkflowsRequest 获得工作流列表请求结构

func (*ListWorkflowsRequest) Descriptor deprecated 

func (*ListWorkflowsRequest) Descriptor() ([]byte, []int)

Deprecated: Use ListWorkflowsRequest.ProtoReflect.Descriptor instead.

func (*ListWorkflowsRequest) GetNamespace 

func (x *ListWorkflowsRequest) GetNamespace() string

func (*ListWorkflowsRequest) GetPageRequest 

func (x *ListWorkflowsRequest) GetPageRequest() *PageRequest

func (*ListWorkflowsRequest) ProtoMessage 

func (*ListWorkflowsRequest) ProtoMessage()

func (*ListWorkflowsRequest) ProtoReflect 

func (x *ListWorkflowsRequest) ProtoReflect() protoreflect.Message

func (*ListWorkflowsRequest) Reset 

func (x *ListWorkflowsRequest) Reset()

func (*ListWorkflowsRequest) String 

func (x *ListWorkflowsRequest) String() string

type ListWorkflowsResponse 

type ListWorkflowsResponse struct {

	// 查询到的执行列表
	Data []*WorkflowInfo `protobuf:"bytes,1,rep,name=data,proto3" json:"data,omitempty"`
	// 分页信息
	PageResponse *PageResponse `protobuf:"bytes,2,opt,name=page_response,json=pageResponse,proto3" json:"page_response,omitempty"`
	// contains filtered or unexported fields
}

ListWorkflowsResponse 获得工作流列表请求返回

func (*ListWorkflowsResponse) Descriptor deprecated 

func (*ListWorkflowsResponse) Descriptor() ([]byte, []int)

Deprecated: Use ListWorkflowsResponse.ProtoReflect.Descriptor instead.

func (*ListWorkflowsResponse) GetData 

func (x *ListWorkflowsResponse) GetData() []*WorkflowInfo

func (*ListWorkflowsResponse) GetPageResponse 

func (x *ListWorkflowsResponse) GetPageResponse() *PageResponse

func (*ListWorkflowsResponse) ProtoMessage 

func (*ListWorkflowsResponse) ProtoMessage()

func (*ListWorkflowsResponse) ProtoReflect 

func (x *ListWorkflowsResponse) ProtoReflect() protoreflect.Message

func (*ListWorkflowsResponse) Reset 

func (x *ListWorkflowsResponse) Reset()

func (*ListWorkflowsResponse) String 

func (x *ListWorkflowsResponse) String() string

type LoadTaskDataRequest 

type LoadTaskDataRequest struct {

	// step id
	StepId int64 `protobuf:"varint,1,opt,name=step_id,json=stepId,proto3" json:"step_id,omitempty"`
	// contains filtered or unexported fields
}

LoadTaskDataRequest 获得task 临时数据

func (*LoadTaskDataRequest) Descriptor deprecated 

func (*LoadTaskDataRequest) Descriptor() ([]byte, []int)

Deprecated: Use LoadTaskDataRequest.ProtoReflect.Descriptor instead.

func (*LoadTaskDataRequest) GetStepId 

func (x *LoadTaskDataRequest) GetStepId() int64

func (*LoadTaskDataRequest) ProtoMessage 

func (*LoadTaskDataRequest) ProtoMessage()

func (*LoadTaskDataRequest) ProtoReflect 

func (x *LoadTaskDataRequest) ProtoReflect() protoreflect.Message

func (*LoadTaskDataRequest) Reset 

func (x *LoadTaskDataRequest) Reset()

func (*LoadTaskDataRequest) String 

func (x *LoadTaskDataRequest) String() string

type LoadTaskDataResponse 

type LoadTaskDataResponse struct {

	// task 临时数据
	Data string `protobuf:"bytes,1,opt,name=data,proto3" json:"data,omitempty"`
	// contains filtered or unexported fields
}

LoadTaskDataResponse 获得task 临时数据

func (*LoadTaskDataResponse) Descriptor deprecated 

func (*LoadTaskDataResponse) Descriptor() ([]byte, []int)

Deprecated: Use LoadTaskDataResponse.ProtoReflect.Descriptor instead.

func (*LoadTaskDataResponse) GetData 

func (x *LoadTaskDataResponse) GetData() string

func (*LoadTaskDataResponse) ProtoMessage 

func (*LoadTaskDataResponse) ProtoMessage()

func (*LoadTaskDataResponse) ProtoReflect 

func (x *LoadTaskDataResponse) ProtoReflect() protoreflect.Message

func (*LoadTaskDataResponse) Reset 

func (x *LoadTaskDataResponse) Reset()

func (*LoadTaskDataResponse) String 

func (x *LoadTaskDataResponse) String() string

type MockCommonClientProxy 

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

MockCommonClientProxy is a mock of CommonClientProxy interface.

func NewMockCommonClientProxy 

func NewMockCommonClientProxy(ctrl *gomock.Controller) *MockCommonClientProxy

NewMockCommonClientProxy creates a new mock instance.

func (*MockCommonClientProxy) EXPECT 

func (m *MockCommonClientProxy) EXPECT() *MockCommonClientProxyMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

func (*MockCommonClientProxy) HTTP 

func (m *MockCommonClientProxy) HTTP(ctx context.Context, req *emptypb.Empty, opts ...client.Option) (*HTTPResponseMessage, error)

HTTP mocks base method.

func (*MockCommonClientProxy) Paging 

func (m *MockCommonClientProxy) Paging(ctx context.Context, req *PageRequest, opts ...client.Option) (*PageResponse, error)

Paging mocks base method.

type MockCommonClientProxyMockRecorder 

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

MockCommonClientProxyMockRecorder is the mock recorder for MockCommonClientProxy.

func (*MockCommonClientProxyMockRecorder) HTTP 

func (mr *MockCommonClientProxyMockRecorder) HTTP(ctx, req interface{}, opts ...interface{}) *gomock.Call

HTTP indicates an expected call of HTTP.

func (*MockCommonClientProxyMockRecorder) Paging 

func (mr *MockCommonClientProxyMockRecorder) Paging(ctx, req interface{}, opts ...interface{}) *gomock.Call

Paging indicates an expected call of Paging.

type MockCommonService 

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

MockCommonService is a mock of CommonService interface.

func NewMockCommonService 

func NewMockCommonService(ctrl *gomock.Controller) *MockCommonService

NewMockCommonService creates a new mock instance.

func (*MockCommonService) EXPECT 

func (m *MockCommonService) EXPECT() *MockCommonServiceMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

func (*MockCommonService) HTTP 

func (m *MockCommonService) HTTP(ctx context.Context, req *emptypb.Empty) (*HTTPResponseMessage, error)

HTTP mocks base method.

func (*MockCommonService) Paging 

func (m *MockCommonService) Paging(ctx context.Context, req *PageRequest) (*PageResponse, error)

Paging mocks base method.

type MockCommonServiceMockRecorder 

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

MockCommonServiceMockRecorder is the mock recorder for MockCommonService.

func (*MockCommonServiceMockRecorder) HTTP 

func (mr *MockCommonServiceMockRecorder) HTTP(ctx, req interface{}) *gomock.Call

HTTP indicates an expected call of HTTP.

func (*MockCommonServiceMockRecorder) Paging 

func (mr *MockCommonServiceMockRecorder) Paging(ctx, req interface{}) *gomock.Call

Paging indicates an expected call of Paging.

type MockSkyflowClientProxy 

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

MockSkyflowClientProxy is a mock of SkyflowClientProxy interface.

func NewMockSkyflowClientProxy 

func NewMockSkyflowClientProxy(ctrl *gomock.Controller) *MockSkyflowClientProxy

NewMockSkyflowClientProxy creates a new mock instance.

func (*MockSkyflowClientProxy) CreateActivity 

func (m *MockSkyflowClientProxy) CreateActivity(ctx context.Context, req *CreateActivityRequest, opts ...client.Option) (*CreateActivityResponse, error)

CreateActivity mocks base method.

func (*MockSkyflowClientProxy) CreateNamespace 

func (m *MockSkyflowClientProxy) CreateNamespace(ctx context.Context, req *CreateNamespaceRequest, opts ...client.Option) (*CreateNamespaceResponse, error)

CreateNamespace mocks base method.

func (*MockSkyflowClientProxy) DescribeActivity 

func (m *MockSkyflowClientProxy) DescribeActivity(ctx context.Context, req *DescribeActivityRequest, opts ...client.Option) (*DescribeActivityResponse, error)

DescribeActivity mocks base method.

func (*MockSkyflowClientProxy) EXPECT 

func (m *MockSkyflowClientProxy) EXPECT() *MockSkyflowClientProxyMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

func (*MockSkyflowClientProxy) ListActivities 

func (m *MockSkyflowClientProxy) ListActivities(ctx context.Context, req *ListActivitiesRequest, opts ...client.Option) (*ListActivitiesResponse, error)

ListActivities mocks base method.

func (*MockSkyflowClientProxy) ListNamespaces 

func (m *MockSkyflowClientProxy) ListNamespaces(ctx context.Context, req *ListNamespacesRequest, opts ...client.Option) (*ListNamespacesResponse, error)

ListNamespaces mocks base method.

type MockSkyflowClientProxyMockRecorder 

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

MockSkyflowClientProxyMockRecorder is the mock recorder for MockSkyflowClientProxy.

func (*MockSkyflowClientProxyMockRecorder) CreateActivity 

func (mr *MockSkyflowClientProxyMockRecorder) CreateActivity(ctx, req interface{}, opts ...interface{}) *gomock.Call

CreateActivity indicates an expected call of CreateActivity.

func (*MockSkyflowClientProxyMockRecorder) CreateNamespace 

func (mr *MockSkyflowClientProxyMockRecorder) CreateNamespace(ctx, req interface{}, opts ...interface{}) *gomock.Call

CreateNamespace indicates an expected call of CreateNamespace.

func (*MockSkyflowClientProxyMockRecorder) DescribeActivity 

func (mr *MockSkyflowClientProxyMockRecorder) DescribeActivity(ctx, req interface{}, opts ...interface{}) *gomock.Call

DescribeActivity indicates an expected call of DescribeActivity.

func (*MockSkyflowClientProxyMockRecorder) ListActivities 

func (mr *MockSkyflowClientProxyMockRecorder) ListActivities(ctx, req interface{}, opts ...interface{}) *gomock.Call

ListActivities indicates an expected call of ListActivities.

func (*MockSkyflowClientProxyMockRecorder) ListNamespaces 

func (mr *MockSkyflowClientProxyMockRecorder) ListNamespaces(ctx, req interface{}, opts ...interface{}) *gomock.Call

ListNamespaces indicates an expected call of ListNamespaces.

type MockSkyflowService 

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

MockSkyflowService is a mock of SkyflowService interface.

func NewMockSkyflowService 

func NewMockSkyflowService(ctrl *gomock.Controller) *MockSkyflowService

NewMockSkyflowService creates a new mock instance.

func (*MockSkyflowService) CreateActivity 

func (m *MockSkyflowService) CreateActivity(ctx context.Context, req *CreateActivityRequest) (*CreateActivityResponse, error)

CreateActivity mocks base method.

func (*MockSkyflowService) CreateNamespace 

func (m *MockSkyflowService) CreateNamespace(ctx context.Context, req *CreateNamespaceRequest) (*CreateNamespaceResponse, error)

CreateNamespace mocks base method.

func (*MockSkyflowService) DescribeActivity 

func (m *MockSkyflowService) DescribeActivity(ctx context.Context, req *DescribeActivityRequest) (*DescribeActivityResponse, error)

DescribeActivity mocks base method.

func (*MockSkyflowService) EXPECT 

func (m *MockSkyflowService) EXPECT() *MockSkyflowServiceMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

func (*MockSkyflowService) ListActivities 

func (m *MockSkyflowService) ListActivities(ctx context.Context, req *ListActivitiesRequest) (*ListActivitiesResponse, error)

ListActivities mocks base method.

func (*MockSkyflowService) ListNamespaces 

func (m *MockSkyflowService) ListNamespaces(ctx context.Context, req *ListNamespacesRequest) (*ListNamespacesResponse, error)

ListNamespaces mocks base method.

type MockSkyflowServiceMockRecorder 

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

MockSkyflowServiceMockRecorder is the mock recorder for MockSkyflowService.

func (*MockSkyflowServiceMockRecorder) CreateActivity 

func (mr *MockSkyflowServiceMockRecorder) CreateActivity(ctx, req interface{}) *gomock.Call

CreateActivity indicates an expected call of CreateActivity.

func (*MockSkyflowServiceMockRecorder) CreateNamespace 

func (mr *MockSkyflowServiceMockRecorder) CreateNamespace(ctx, req interface{}) *gomock.Call

CreateNamespace indicates an expected call of CreateNamespace.

func (*MockSkyflowServiceMockRecorder) DescribeActivity 

func (mr *MockSkyflowServiceMockRecorder) DescribeActivity(ctx, req interface{}) *gomock.Call

DescribeActivity indicates an expected call of DescribeActivity.

func (*MockSkyflowServiceMockRecorder) ListActivities 

func (mr *MockSkyflowServiceMockRecorder) ListActivities(ctx, req interface{}) *gomock.Call

ListActivities indicates an expected call of ListActivities.

func (*MockSkyflowServiceMockRecorder) ListNamespaces 

func (mr *MockSkyflowServiceMockRecorder) ListNamespaces(ctx, req interface{}) *gomock.Call

ListNamespaces indicates an expected call of ListNamespaces.

type NamespaceInfo 

type NamespaceInfo struct {
	Name       string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Comment    string `protobuf:"bytes,2,opt,name=comment,proto3" json:"comment,omitempty"`
	CreateTime string `protobuf:"bytes,11,opt,name=create_time,json=createTime,proto3" json:"create_time,omitempty"`
	ModifyTime string `protobuf:"bytes,12,opt,name=modify_time,json=modifyTime,proto3" json:"modify_time,omitempty"`
	// contains filtered or unexported fields
}

NamespaceInfo 命名空间信息

func (*NamespaceInfo) Descriptor deprecated 

func (*NamespaceInfo) Descriptor() ([]byte, []int)

Deprecated: Use NamespaceInfo.ProtoReflect.Descriptor instead.

func (*NamespaceInfo) GetComment 

func (x *NamespaceInfo) GetComment() string

func (*NamespaceInfo) GetCreateTime 

func (x *NamespaceInfo) GetCreateTime() string

func (*NamespaceInfo) GetModifyTime 

func (x *NamespaceInfo) GetModifyTime() string

func (*NamespaceInfo) GetName 

func (x *NamespaceInfo) GetName() string

func (*NamespaceInfo) ProtoMessage 

func (*NamespaceInfo) ProtoMessage()

func (*NamespaceInfo) ProtoReflect 

func (x *NamespaceInfo) ProtoReflect() protoreflect.Message

func (*NamespaceInfo) Reset 

func (x *NamespaceInfo) Reset()

func (*NamespaceInfo) String 

func (x *NamespaceInfo) String() string

type PageRequest 

type PageRequest struct {

	// 请求分页大小
	PageSize int64 `protobuf:"varint,1,opt,name=page_size,json=pageSize,proto3" json:"page_size,omitempty"`
	// 请求页号
	PageNumber int64 `protobuf:"varint,2,opt,name=page_number,json=pageNumber,proto3" json:"page_number,omitempty"`
	// 请求排序字段
	OrderBy string `protobuf:"bytes,3,opt,name=order_by,json=orderBy,proto3" json:"order_by,omitempty"`
	// contains filtered or unexported fields
}

分页请求结构

func (*PageRequest) Descriptor deprecated 

func (*PageRequest) Descriptor() ([]byte, []int)

Deprecated: Use PageRequest.ProtoReflect.Descriptor instead.

func (*PageRequest) GetOrderBy 

func (x *PageRequest) GetOrderBy() string

func (*PageRequest) GetPageNumber 

func (x *PageRequest) GetPageNumber() int64

func (*PageRequest) GetPageSize 

func (x *PageRequest) GetPageSize() int64

func (*PageRequest) ProtoMessage 

func (*PageRequest) ProtoMessage()

func (*PageRequest) ProtoReflect 

func (x *PageRequest) ProtoReflect() protoreflect.Message

func (*PageRequest) Reset 

func (x *PageRequest) Reset()

func (*PageRequest) String 

func (x *PageRequest) String() string

type PageResponse 

type PageResponse struct {

	// 总数量
	Count int64 `protobuf:"varint,1,opt,name=count,proto3" json:"count,omitempty"`
	// 请求分页大小
	PageSize int64 `protobuf:"varint,2,opt,name=page_size,json=pageSize,proto3" json:"page_size,omitempty"`
	// 请求页号
	PageNumber int64 `protobuf:"varint,3,opt,name=page_number,json=pageNumber,proto3" json:"page_number,omitempty"`
	// 总页数
	PageCount int64 `protobuf:"varint,4,opt,name=page_count,json=pageCount,proto3" json:"page_count,omitempty"`
	// contains filtered or unexported fields
}

分页返回结构

func (*PageResponse) Descriptor deprecated 

func (*PageResponse) Descriptor() ([]byte, []int)

Deprecated: Use PageResponse.ProtoReflect.Descriptor instead.

func (*PageResponse) GetCount 

func (x *PageResponse) GetCount() int64

func (*PageResponse) GetPageCount 

func (x *PageResponse) GetPageCount() int64

func (*PageResponse) GetPageNumber 

func (x *PageResponse) GetPageNumber() int64

func (*PageResponse) GetPageSize 

func (x *PageResponse) GetPageSize() int64

func (*PageResponse) ProtoMessage 

func (*PageResponse) ProtoMessage()

func (*PageResponse) ProtoReflect 

func (x *PageResponse) ProtoReflect() protoreflect.Message

func (*PageResponse) Reset 

func (x *PageResponse) Reset()

func (*PageResponse) String 

func (x *PageResponse) String() string

type ParseWorkflowRequest 

type ParseWorkflowRequest struct {

	// flow定义
	WorkflowDefinition string `protobuf:"bytes,1,opt,name=workflow_definition,json=workflowDefinition,proto3" json:"workflow_definition,omitempty"`
	// contains filtered or unexported fields
}

ParseWorkflowRequest 解析一个工作流请求结构`

func (*ParseWorkflowRequest) Descriptor deprecated 

func (*ParseWorkflowRequest) Descriptor() ([]byte, []int)

Deprecated: Use ParseWorkflowRequest.ProtoReflect.Descriptor instead.

func (*ParseWorkflowRequest) GetWorkflowDefinition 

func (x *ParseWorkflowRequest) GetWorkflowDefinition() string

func (*ParseWorkflowRequest) ProtoMessage 

func (*ParseWorkflowRequest) ProtoMessage()

func (*ParseWorkflowRequest) ProtoReflect 

func (x *ParseWorkflowRequest) ProtoReflect() protoreflect.Message

func (*ParseWorkflowRequest) Reset 

func (x *ParseWorkflowRequest) Reset()

func (*ParseWorkflowRequest) String 

func (x *ParseWorkflowRequest) String() string

type ParseWorkflowResponse 

type ParseWorkflowResponse struct {

	// flow 类型
	WorkflowType string `protobuf:"bytes,1,opt,name=workflow_type,json=workflowType,proto3" json:"workflow_type,omitempty"`
	// flow 详细定义
	WorkflowDetail string `protobuf:"bytes,2,opt,name=workflow_detail,json=workflowDetail,proto3" json:"workflow_detail,omitempty"`
	// contains filtered or unexported fields
}

ParseWorkflowResponse 解析一个工作流返回结构

func (*ParseWorkflowResponse) Descriptor deprecated 

func (*ParseWorkflowResponse) Descriptor() ([]byte, []int)

Deprecated: Use ParseWorkflowResponse.ProtoReflect.Descriptor instead.

func (*ParseWorkflowResponse) GetWorkflowDetail 

func (x *ParseWorkflowResponse) GetWorkflowDetail() string

func (*ParseWorkflowResponse) GetWorkflowType 

func (x *ParseWorkflowResponse) GetWorkflowType() string

func (*ParseWorkflowResponse) ProtoMessage 

func (*ParseWorkflowResponse) ProtoMessage()

func (*ParseWorkflowResponse) ProtoReflect 

func (x *ParseWorkflowResponse) ProtoReflect() protoreflect.Message

func (*ParseWorkflowResponse) Reset 

func (x *ParseWorkflowResponse) Reset()

func (*ParseWorkflowResponse) String 

func (x *ParseWorkflowResponse) String() string

type SendStepSkipRequest 

type SendStepSkipRequest struct {

	// step id
	StepId int64 `protobuf:"varint,1,opt,name=step_id,json=stepId,proto3" json:"step_id,omitempty"`
	// 下一个步骤名
	NextStep string `protobuf:"bytes,2,opt,name=next_step,json=nextStep,proto3" json:"next_step,omitempty"`
	// output 当天步骤的输出
	Output string `protobuf:"bytes,3,opt,name=output,proto3" json:"output,omitempty"`
	// contains filtered or unexported fields
}

SendStepSuccessRequest 发送step 成功

func (*SendStepSkipRequest) Descriptor deprecated 

func (*SendStepSkipRequest) Descriptor() ([]byte, []int)

Deprecated: Use SendStepSkipRequest.ProtoReflect.Descriptor instead.

func (*SendStepSkipRequest) GetNextStep 

func (x *SendStepSkipRequest) GetNextStep() string

func (*SendStepSkipRequest) GetOutput 

func (x *SendStepSkipRequest) GetOutput() string

func (*SendStepSkipRequest) GetStepId 

func (x *SendStepSkipRequest) GetStepId() int64

func (*SendStepSkipRequest) ProtoMessage 

func (*SendStepSkipRequest) ProtoMessage()

func (*SendStepSkipRequest) ProtoReflect 

func (x *SendStepSkipRequest) ProtoReflect() protoreflect.Message

func (*SendStepSkipRequest) Reset 

func (x *SendStepSkipRequest) Reset()

func (*SendStepSkipRequest) String 

func (x *SendStepSkipRequest) String() string

type SendTaskFailureRequest 

type SendTaskFailureRequest struct {

	// task token
	TaskToken string `protobuf:"bytes,1,opt,name=task_token,json=taskToken,proto3" json:"task_token,omitempty"`
	// error 错误类型，用来匹配异常
	Error string `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty"`
	// cause， error的文本描述
	Cause string `protobuf:"bytes,3,opt,name=cause,proto3" json:"cause,omitempty"`
	// contains filtered or unexported fields
}

SendTaskFailureRequest 发送task 失败

func (*SendTaskFailureRequest) Descriptor deprecated 

func (*SendTaskFailureRequest) Descriptor() ([]byte, []int)

Deprecated: Use SendTaskFailureRequest.ProtoReflect.Descriptor instead.

func (*SendTaskFailureRequest) GetCause 

func (x *SendTaskFailureRequest) GetCause() string

func (*SendTaskFailureRequest) GetError 

func (x *SendTaskFailureRequest) GetError() string

func (*SendTaskFailureRequest) GetTaskToken 

func (x *SendTaskFailureRequest) GetTaskToken() string

func (*SendTaskFailureRequest) ProtoMessage 

func (*SendTaskFailureRequest) ProtoMessage()

func (*SendTaskFailureRequest) ProtoReflect 

func (x *SendTaskFailureRequest) ProtoReflect() protoreflect.Message

func (*SendTaskFailureRequest) Reset 

func (x *SendTaskFailureRequest) Reset()

func (*SendTaskFailureRequest) String 

func (x *SendTaskFailureRequest) String() string

type SendTaskHeartbeatRequest 

type SendTaskHeartbeatRequest struct {

	// task token
	TaskToken string `protobuf:"bytes,1,opt,name=task_token,json=taskToken,proto3" json:"task_token,omitempty"`
	// task 可以附带的message
	Message string `protobuf:"bytes,3,opt,name=message,proto3" json:"message,omitempty"`
	// contains filtered or unexported fields
}

SendTaskHeartbeatRequest 发送task 心跳

func (*SendTaskHeartbeatRequest) Descriptor deprecated 

func (*SendTaskHeartbeatRequest) Descriptor() ([]byte, []int)

Deprecated: Use SendTaskHeartbeatRequest.ProtoReflect.Descriptor instead.

func (*SendTaskHeartbeatRequest) GetMessage 

func (x *SendTaskHeartbeatRequest) GetMessage() string

func (*SendTaskHeartbeatRequest) GetTaskToken 

func (x *SendTaskHeartbeatRequest) GetTaskToken() string

func (*SendTaskHeartbeatRequest) ProtoMessage 

func (*SendTaskHeartbeatRequest) ProtoMessage()

func (*SendTaskHeartbeatRequest) ProtoReflect 

func (x *SendTaskHeartbeatRequest) ProtoReflect() protoreflect.Message

func (*SendTaskHeartbeatRequest) Reset 

func (x *SendTaskHeartbeatRequest) Reset()

func (*SendTaskHeartbeatRequest) String 

func (x *SendTaskHeartbeatRequest) String() string

type SendTaskReferenceRequest 

type SendTaskReferenceRequest struct {

	// task token
	TaskToken string `protobuf:"bytes,1,opt,name=task_token,json=taskToken,proto3" json:"task_token,omitempty"`
	// task 关联的链接描述
	Title string `protobuf:"bytes,2,opt,name=title,proto3" json:"title,omitempty"`
	// task关联的链接url
	Url string `protobuf:"bytes,3,opt,name=url,proto3" json:"url,omitempty"`
	// contains filtered or unexported fields
}

func (*SendTaskReferenceRequest) Descriptor deprecated 

func (*SendTaskReferenceRequest) Descriptor() ([]byte, []int)

Deprecated: Use SendTaskReferenceRequest.ProtoReflect.Descriptor instead.

func (*SendTaskReferenceRequest) GetTaskToken 

func (x *SendTaskReferenceRequest) GetTaskToken() string

func (*SendTaskReferenceRequest) GetTitle 

func (x *SendTaskReferenceRequest) GetTitle() string

func (*SendTaskReferenceRequest) GetUrl 

func (x *SendTaskReferenceRequest) GetUrl() string

func (*SendTaskReferenceRequest) ProtoMessage 

func (*SendTaskReferenceRequest) ProtoMessage()

func (*SendTaskReferenceRequest) ProtoReflect 

func (x *SendTaskReferenceRequest) ProtoReflect() protoreflect.Message

func (*SendTaskReferenceRequest) Reset 

func (x *SendTaskReferenceRequest) Reset()

func (*SendTaskReferenceRequest) String 

func (x *SendTaskReferenceRequest) String() string

type SendTaskSuccessRequest 

type SendTaskSuccessRequest struct {

	// task token
	TaskToken string `protobuf:"bytes,1,opt,name=task_token,json=taskToken,proto3" json:"task_token,omitempty"`
	// output task 执行的output， json 类型
	Output string `protobuf:"bytes,2,opt,name=output,proto3" json:"output,omitempty"`
	// contains filtered or unexported fields
}

func (*SendTaskSuccessRequest) Descriptor deprecated 

func (*SendTaskSuccessRequest) Descriptor() ([]byte, []int)

Deprecated: Use SendTaskSuccessRequest.ProtoReflect.Descriptor instead.

func (*SendTaskSuccessRequest) GetOutput 

func (x *SendTaskSuccessRequest) GetOutput() string

func (*SendTaskSuccessRequest) GetTaskToken 

func (x *SendTaskSuccessRequest) GetTaskToken() string

func (*SendTaskSuccessRequest) ProtoMessage 

func (*SendTaskSuccessRequest) ProtoMessage()

func (*SendTaskSuccessRequest) ProtoReflect 

func (x *SendTaskSuccessRequest) ProtoReflect() protoreflect.Message

func (*SendTaskSuccessRequest) Reset 

func (x *SendTaskSuccessRequest) Reset()

func (*SendTaskSuccessRequest) String 

func (x *SendTaskSuccessRequest) String() string

type SkipBlockedTaskRequest 

type SkipBlockedTaskRequest struct {

	// step id
	StepId int64 `protobuf:"varint,1,opt,name=step_id,json=stepId,proto3" json:"step_id,omitempty"`
	// contains filtered or unexported fields
}

SkipBlockedTaskRequest 跳过一个阻塞的task

func (*SkipBlockedTaskRequest) Descriptor deprecated 

func (*SkipBlockedTaskRequest) Descriptor() ([]byte, []int)

Deprecated: Use SkipBlockedTaskRequest.ProtoReflect.Descriptor instead.

func (*SkipBlockedTaskRequest) GetStepId 

func (x *SkipBlockedTaskRequest) GetStepId() int64

func (*SkipBlockedTaskRequest) ProtoMessage 

func (*SkipBlockedTaskRequest) ProtoMessage()

func (*SkipBlockedTaskRequest) ProtoReflect 

func (x *SkipBlockedTaskRequest) ProtoReflect() protoreflect.Message

func (*SkipBlockedTaskRequest) Reset 

func (x *SkipBlockedTaskRequest) Reset()

func (*SkipBlockedTaskRequest) String 

func (x *SkipBlockedTaskRequest) String() string

type SkyflowClientProxy 

type SkyflowClientProxy interface {
	// CreateNamespace CreateNamespace 创建一个命名空间
	CreateNamespace(ctx context.Context, req *CreateNamespaceRequest, opts ...client.Option) (rsp *CreateNamespaceResponse, err error)
	// ListNamespaces ListNamespaces 获得命名空间列表
	ListNamespaces(ctx context.Context, req *ListNamespacesRequest, opts ...client.Option) (rsp *ListNamespacesResponse, err error)
	// CreateActivity CreateActivity 创建一个活动
	CreateActivity(ctx context.Context, req *CreateActivityRequest, opts ...client.Option) (rsp *CreateActivityResponse, err error)
	// ListActivities ListActivities 获得活动列表
	ListActivities(ctx context.Context, req *ListActivitiesRequest, opts ...client.Option) (rsp *ListActivitiesResponse, err error)
	// DescribeActivity DescribeActivity 获得一个活动的描述
	DescribeActivity(ctx context.Context, req *DescribeActivityRequest, opts ...client.Option) (rsp *DescribeActivityResponse, err error)
}

SkyflowClientProxy defines service client proxy

type SkyflowClientProxyImpl 

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

func (*SkyflowClientProxyImpl) CreateActivity 

func (c *SkyflowClientProxyImpl) CreateActivity(ctx context.Context, req *CreateActivityRequest, opts ...client.Option) (*CreateActivityResponse, error)

func (*SkyflowClientProxyImpl) CreateNamespace 

func (c *SkyflowClientProxyImpl) CreateNamespace(ctx context.Context, req *CreateNamespaceRequest, opts ...client.Option) (*CreateNamespaceResponse, error)

func (*SkyflowClientProxyImpl) DescribeActivity 

func (c *SkyflowClientProxyImpl) DescribeActivity(ctx context.Context, req *DescribeActivityRequest, opts ...client.Option) (*DescribeActivityResponse, error)

func (*SkyflowClientProxyImpl) ListActivities 

func (c *SkyflowClientProxyImpl) ListActivities(ctx context.Context, req *ListActivitiesRequest, opts ...client.Option) (*ListActivitiesResponse, error)

func (*SkyflowClientProxyImpl) ListNamespaces 

func (c *SkyflowClientProxyImpl) ListNamespaces(ctx context.Context, req *ListNamespacesRequest, opts ...client.Option) (*ListNamespacesResponse, error)

type SkyflowService 

type SkyflowService interface {
	// CreateNamespace CreateNamespace 创建一个命名空间
	CreateNamespace(ctx context.Context, req *CreateNamespaceRequest) (*CreateNamespaceResponse, error)
	// ListNamespaces ListNamespaces 获得命名空间列表
	ListNamespaces(ctx context.Context, req *ListNamespacesRequest) (*ListNamespacesResponse, error)
	// CreateActivity CreateActivity 创建一个活动
	CreateActivity(ctx context.Context, req *CreateActivityRequest) (*CreateActivityResponse, error)
	// ListActivities ListActivities 获得活动列表
	ListActivities(ctx context.Context, req *ListActivitiesRequest) (*ListActivitiesResponse, error)
	// DescribeActivity DescribeActivity 获得一个活动的描述
	DescribeActivity(ctx context.Context, req *DescribeActivityRequest) (*DescribeActivityResponse, error)
}

SkyflowService defines service.

type StartExecutionRequest 

type StartExecutionRequest struct {

	// 工作流模板URI，可选，workflow_uri 与workflow_definition 必须指定一个
	WorkflowUri string `protobuf:"bytes,1,opt,name=workflow_uri,json=workflowUri,proto3" json:"workflow_uri,omitempty"`
	// 流程模板定义，JSON/YAML格式的流程模板定义，可选
	WorkflowDefinition string `protobuf:"bytes,2,opt,name=workflow_definition,json=workflowDefinition,proto3" json:"workflow_definition,omitempty"`
	// 工作流执行的标题，可为空
	Title string `protobuf:"bytes,3,opt,name=title,proto3" json:"title,omitempty"`
	// 工作流执行的输入，json格式的输入 ，可选，默认是空 '{}'
	Input string `protobuf:"bytes,4,opt,name=input,proto3" json:"input,omitempty"`
	// 工作流执行的任务ID， 全局不可重复 uuid， 可选，不指定自动生成uuid
	ExecutionName string `protobuf:"bytes,5,opt,name=execution_name,json=executionName,proto3" json:"execution_name,omitempty"`
	// contains filtered or unexported fields
}

创建一个执行的请求体 参数约束： workflow_uri 是指注册到 skyflowflow的 模板引用路径， workflow_definition是自定义的workflow定义,jons/yaml格式 workflow_uri与workflow_definition 二选一。 execution_name：用户自定义的执行唯一名称，可选， 如果指定，自动生成一个新的uuid .

func (*StartExecutionRequest) Descriptor deprecated 

func (*StartExecutionRequest) Descriptor() ([]byte, []int)

Deprecated: Use StartExecutionRequest.ProtoReflect.Descriptor instead.

func (*StartExecutionRequest) GetExecutionName 

func (x *StartExecutionRequest) GetExecutionName() string

func (*StartExecutionRequest) GetInput 

func (x *StartExecutionRequest) GetInput() string

func (*StartExecutionRequest) GetTitle 

func (x *StartExecutionRequest) GetTitle() string

func (*StartExecutionRequest) GetWorkflowDefinition 

func (x *StartExecutionRequest) GetWorkflowDefinition() string

func (*StartExecutionRequest) GetWorkflowUri 

func (x *StartExecutionRequest) GetWorkflowUri() string

func (*StartExecutionRequest) ProtoMessage 

func (*StartExecutionRequest) ProtoMessage()

func (*StartExecutionRequest) ProtoReflect 

func (x *StartExecutionRequest) ProtoReflect() protoreflect.Message

func (*StartExecutionRequest) Reset 

func (x *StartExecutionRequest) Reset()

func (*StartExecutionRequest) String 

func (x *StartExecutionRequest) String() string

type StartExecutionResponse 

type StartExecutionResponse struct {

	// 返回的执行的唯一ID
	ExecutionUuid string `protobuf:"bytes,1,opt,name=execution_uuid,json=executionUuid,proto3" json:"execution_uuid,omitempty"`
	// 执行创建的时间
	CreateTime string `protobuf:"bytes,2,opt,name=create_time,json=createTime,proto3" json:"create_time,omitempty"`
	// contains filtered or unexported fields
}

创建一个执行的请求返回结构

func (*StartExecutionResponse) Descriptor deprecated 

func (*StartExecutionResponse) Descriptor() ([]byte, []int)

Deprecated: Use StartExecutionResponse.ProtoReflect.Descriptor instead.

func (*StartExecutionResponse) GetCreateTime 

func (x *StartExecutionResponse) GetCreateTime() string

func (*StartExecutionResponse) GetExecutionUuid 

func (x *StartExecutionResponse) GetExecutionUuid() string

func (*StartExecutionResponse) ProtoMessage 

func (*StartExecutionResponse) ProtoMessage()

func (*StartExecutionResponse) ProtoReflect 

func (x *StartExecutionResponse) ProtoReflect() protoreflect.Message

func (*StartExecutionResponse) Reset 

func (x *StartExecutionResponse) Reset()

func (*StartExecutionResponse) String 

func (x *StartExecutionResponse) String() string

type StepInfo 

type StepInfo struct {
	Id             int64  `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	Status         string `protobuf:"bytes,2,opt,name=status,proto3" json:"status,omitempty"`
	StepDefinition string `protobuf:"bytes,4,opt,name=step_definition,json=stepDefinition,proto3" json:"step_definition,omitempty"`
	Input          string `protobuf:"bytes,5,opt,name=input,proto3" json:"input,omitempty"`
	Output         string `protobuf:"bytes,6,opt,name=output,proto3" json:"output,omitempty"`
	CreateTime     string `protobuf:"bytes,11,opt,name=create_time,json=createTime,proto3" json:"create_time,omitempty"`
	StartTime      string `protobuf:"bytes,12,opt,name=start_time,json=startTime,proto3" json:"start_time,omitempty"`
	FinishTime     string `protobuf:"bytes,13,opt,name=finish_time,json=finishTime,proto3" json:"finish_time,omitempty"`
	// contains filtered or unexported fields
}

StepInfo 一个step的状态描述

func (*StepInfo) Descriptor deprecated 

func (*StepInfo) Descriptor() ([]byte, []int)

Deprecated: Use StepInfo.ProtoReflect.Descriptor instead.

func (*StepInfo) GetCreateTime 

func (x *StepInfo) GetCreateTime() string

func (*StepInfo) GetFinishTime 

func (x *StepInfo) GetFinishTime() string

func (*StepInfo) GetId 

func (x *StepInfo) GetId() int64

func (*StepInfo) GetInput 

func (x *StepInfo) GetInput() string

func (*StepInfo) GetOutput 

func (x *StepInfo) GetOutput() string

func (*StepInfo) GetStartTime 

func (x *StepInfo) GetStartTime() string

func (*StepInfo) GetStatus 

func (x *StepInfo) GetStatus() string

func (*StepInfo) GetStepDefinition 

func (x *StepInfo) GetStepDefinition() string

func (*StepInfo) ProtoMessage 

func (*StepInfo) ProtoMessage()

func (*StepInfo) ProtoReflect 

func (x *StepInfo) ProtoReflect() protoreflect.Message

func (*StepInfo) Reset 

func (x *StepInfo) Reset()

func (*StepInfo) String 

func (x *StepInfo) String() string

type StopExecutionRequest 

type StopExecutionRequest struct {

	// execution uuid， 必选
	ExecutionUuid string `protobuf:"bytes,1,opt,name=execution_uuid,json=executionUuid,proto3" json:"execution_uuid,omitempty"`
	// Error 错误类型，用来匹配异常, 必选
	Error string `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty"`
	// cause， error的文本描述， 可选
	Cause string `protobuf:"bytes,3,opt,name=cause,proto3" json:"cause,omitempty"`
	// contains filtered or unexported fields
}

终止一个执行

func (*StopExecutionRequest) Descriptor deprecated 

func (*StopExecutionRequest) Descriptor() ([]byte, []int)

Deprecated: Use StopExecutionRequest.ProtoReflect.Descriptor instead.

func (*StopExecutionRequest) GetCause 

func (x *StopExecutionRequest) GetCause() string

func (*StopExecutionRequest) GetError 

func (x *StopExecutionRequest) GetError() string

func (*StopExecutionRequest) GetExecutionUuid 

func (x *StopExecutionRequest) GetExecutionUuid() string

func (*StopExecutionRequest) ProtoMessage 

func (*StopExecutionRequest) ProtoMessage()

func (*StopExecutionRequest) ProtoReflect 

func (x *StopExecutionRequest) ProtoReflect() protoreflect.Message

func (*StopExecutionRequest) Reset 

func (x *StopExecutionRequest) Reset()

func (*StopExecutionRequest) String 

func (x *StopExecutionRequest) String() string

type StoreTaskDataRequest 

type StoreTaskDataRequest struct {

	// task token
	TaskToken string `protobuf:"bytes,1,opt,name=task_token,json=taskToken,proto3" json:"task_token,omitempty"`
	// task 临时数据
	Data string `protobuf:"bytes,2,opt,name=data,proto3" json:"data,omitempty"`
	// contains filtered or unexported fields
}

StoreTaskDataRequest 存储task 临时数据

func (*StoreTaskDataRequest) Descriptor deprecated 

func (*StoreTaskDataRequest) Descriptor() ([]byte, []int)

Deprecated: Use StoreTaskDataRequest.ProtoReflect.Descriptor instead.

func (*StoreTaskDataRequest) GetData 

func (x *StoreTaskDataRequest) GetData() string

func (*StoreTaskDataRequest) GetTaskToken 

func (x *StoreTaskDataRequest) GetTaskToken() string

func (*StoreTaskDataRequest) ProtoMessage 

func (*StoreTaskDataRequest) ProtoMessage()

func (*StoreTaskDataRequest) ProtoReflect 

func (x *StoreTaskDataRequest) ProtoReflect() protoreflect.Message

func (*StoreTaskDataRequest) Reset 

func (x *StoreTaskDataRequest) Reset()

func (*StoreTaskDataRequest) String 

func (x *StoreTaskDataRequest) String() string

type UnblockTaskRequest 

type UnblockTaskRequest struct {

	// step id
	StepId int64 `protobuf:"varint,1,opt,name=step_id,json=stepId,proto3" json:"step_id,omitempty"`
	// contains filtered or unexported fields
}

BlockTaskRequest 阻塞一个task

func (*UnblockTaskRequest) Descriptor deprecated 

func (*UnblockTaskRequest) Descriptor() ([]byte, []int)

Deprecated: Use UnblockTaskRequest.ProtoReflect.Descriptor instead.

func (*UnblockTaskRequest) GetStepId 

func (x *UnblockTaskRequest) GetStepId() int64

func (*UnblockTaskRequest) ProtoMessage 

func (*UnblockTaskRequest) ProtoMessage()

func (*UnblockTaskRequest) ProtoReflect 

func (x *UnblockTaskRequest) ProtoReflect() protoreflect.Message

func (*UnblockTaskRequest) Reset 

func (x *UnblockTaskRequest) Reset()

func (*UnblockTaskRequest) String 

func (x *UnblockTaskRequest) String() string

type UnimplementedCommon 

type UnimplementedCommon struct{}

func (*UnimplementedCommon) HTTP 

func (s *UnimplementedCommon) HTTP(ctx context.Context, req *emptypb.Empty) (*HTTPResponseMessage, error)

HTTP HTTPReturn HTTP API接口返回值格式

func (*UnimplementedCommon) Paging 

func (s *UnimplementedCommon) Paging(ctx context.Context, req *PageRequest) (*PageResponse, error)

Paging Paging 分页格式

type UnimplementedSkyflow 

type UnimplementedSkyflow struct{}

func (*UnimplementedSkyflow) CreateActivity 

func (s *UnimplementedSkyflow) CreateActivity(ctx context.Context, req *CreateActivityRequest) (*CreateActivityResponse, error)

CreateActivity CreateActivity 创建一个活动

func (*UnimplementedSkyflow) CreateNamespace 

func (s *UnimplementedSkyflow) CreateNamespace(ctx context.Context, req *CreateNamespaceRequest) (*CreateNamespaceResponse, error)

CreateNamespace CreateNamespace 创建一个命名空间

func (*UnimplementedSkyflow) DescribeActivity 

func (s *UnimplementedSkyflow) DescribeActivity(ctx context.Context, req *DescribeActivityRequest) (*DescribeActivityResponse, error)

DescribeActivity DescribeActivity 获得一个活动的描述

func (*UnimplementedSkyflow) ListActivities 

func (s *UnimplementedSkyflow) ListActivities(ctx context.Context, req *ListActivitiesRequest) (*ListActivitiesResponse, error)

ListActivities ListActivities 获得活动列表

func (*UnimplementedSkyflow) ListNamespaces 

func (s *UnimplementedSkyflow) ListNamespaces(ctx context.Context, req *ListNamespacesRequest) (*ListNamespacesResponse, error)

ListNamespaces ListNamespaces 获得命名空间列表

type WorkflowInfo 

type WorkflowInfo struct {
	Name               string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Comment            string `protobuf:"bytes,2,opt,name=comment,proto3" json:"comment,omitempty"`
	WorkflowUri        string `protobuf:"bytes,3,opt,name=workflow_uri,json=workflowUri,proto3" json:"workflow_uri,omitempty"`
	WorkflowDefinition string `protobuf:"bytes,4,opt,name=workflow_definition,json=workflowDefinition,proto3" json:"workflow_definition,omitempty"`
	// workflow类型; pipeline/statemachine
	WorkflowType string `protobuf:"bytes,5,opt,name=workflow_type,json=workflowType,proto3" json:"workflow_type,omitempty"`
	CreateTime   string `protobuf:"bytes,11,opt,name=create_time,json=createTime,proto3" json:"create_time,omitempty"`
	ModifyTime   string `protobuf:"bytes,12,opt,name=modify_time,json=modifyTime,proto3" json:"modify_time,omitempty"`
	// contains filtered or unexported fields
}

WorkflowInfo 工作流信息

func (*WorkflowInfo) Descriptor deprecated 

func (*WorkflowInfo) Descriptor() ([]byte, []int)

Deprecated: Use WorkflowInfo.ProtoReflect.Descriptor instead.

func (*WorkflowInfo) GetComment 

func (x *WorkflowInfo) GetComment() string

func (*WorkflowInfo) GetCreateTime 

func (x *WorkflowInfo) GetCreateTime() string

func (*WorkflowInfo) GetModifyTime 

func (x *WorkflowInfo) GetModifyTime() string

func (*WorkflowInfo) GetName 

func (x *WorkflowInfo) GetName() string

func (*WorkflowInfo) GetWorkflowDefinition 

func (x *WorkflowInfo) GetWorkflowDefinition() string

func (*WorkflowInfo) GetWorkflowType 

func (x *WorkflowInfo) GetWorkflowType() string

func (*WorkflowInfo) GetWorkflowUri 

func (x *WorkflowInfo) GetWorkflowUri() string

func (*WorkflowInfo) ProtoMessage 

func (*WorkflowInfo) ProtoMessage()

func (*WorkflowInfo) ProtoReflect 

func (x *WorkflowInfo) ProtoReflect() protoreflect.Message

func (*WorkflowInfo) Reset 

func (x *WorkflowInfo) Reset()

func (*WorkflowInfo) String 

func (x *WorkflowInfo) String() string

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.