execute

package
v0.0.0-...-b63aa1a Latest Latest
Warning

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

 Go to latest Published: Dec 18, 2019 License: Apache-2.0 Imports: 13 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func RegisterService 

func RegisterService(s giraffe_micro.Server, srv Service)

Types

type Client 

type Client interface {
	ExecuteFlow(ctx context.Context, in *ExecuteFlowRequest) (*ExecuteFlowResponse, error)
	GetFlowResult(ctx context.Context, in *GetFlowResultRequest) (*flow.FlowInstance, error)
	RetryStep(ctx context.Context, in *RetryStepRequest) (*RetryStepResponse, error)
}

Client is the client API for execute service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewClient 

func NewClient(c giraffe_micro.Client) Client

type ExecuteFlowRequest 

type ExecuteFlowRequest struct {
	//
	//流程执行时输入参数
	//"flowInputs": {
	//"@agents": [
	//{
	//"ip": "192.168.100.163",
	//"instanceId": "5caee6c67d86a"
	//}
	//],
	//"test1": "test params",
	//"ddddd": "5caee6c67d86a",
	//"test2": "develop_1"
	//},
	//
	FlowInputs *types.Struct `protobuf:"bytes,1,opt,name=flowInputs,proto3" json:"flowInputs" form:"flowInputs"`
	//
	//自动填充参数
	InstanceMap *types.Struct `protobuf:"bytes,2,opt,name=instanceMap,proto3" json:"instanceMap" form:"instanceMap"`
	//
	//是否发送notify通知
	NeedNotify bool `protobuf:"varint,3,opt,name=needNotify,proto3" json:"needNotify" form:"needNotify"`
	//
	//父流程任务ID
	ParentTaskId string `protobuf:"bytes,4,opt,name=parentTaskId,proto3" json:"parentTaskId" form:"parentTaskId"`
	//
	//流程执行成功后的回调,有中间态回调,(部署在使用)
	Callback *tool.Callback `protobuf:"bytes,5,opt,name=callback,proto3" json:"callback" form:"callback"`
	//
	//流程全部执行完回调,有别于callback字段
	EndCallback *tool.Callback `protobuf:"bytes,6,opt,name=endCallback,proto3" json:"endCallback" form:"endCallback"`
	//
	//流程ID
	FlowId string `protobuf:"bytes,7,opt,name=flowId,proto3" json:"flowId" form:"flowId"`
	//
	//版本号(时间戳-秒)
	Version int32 `protobuf:"varint,8,opt,name=version,proto3" json:"version" form:"version"`
	//
	//流程名称
	Name string `protobuf:"bytes,9,opt,name=name,proto3" json:"name" form:"name"`
	//
	//流程环境变量 { "youcash":"1234",
	//}
	FlowEnv *types.Value `protobuf:"bytes,10,opt,name=flowEnv,proto3" json:"flowEnv" form:"flowEnv"`
	//
	//流程环境类型
	Metadata *ExecuteFlowRequest_Metadata `protobuf:"bytes,11,opt,name=metadata,proto3" json:"metadata" form:"metadata"`
	//
	//流程标签
	Tags                 []string `protobuf:"bytes,12,rep,name=tags,proto3" json:"tags" form:"tags"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

ExecuteFlow请求

func (*ExecuteFlowRequest) Descriptor 

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

func (*ExecuteFlowRequest) GetCallback 

func (m *ExecuteFlowRequest) GetCallback() *tool.Callback

func (*ExecuteFlowRequest) GetEndCallback 

func (m *ExecuteFlowRequest) GetEndCallback() *tool.Callback

func (*ExecuteFlowRequest) GetFlowEnv 

func (m *ExecuteFlowRequest) GetFlowEnv() *types.Value

func (*ExecuteFlowRequest) GetFlowId 

func (m *ExecuteFlowRequest) GetFlowId() string

func (*ExecuteFlowRequest) GetFlowInputs 

func (m *ExecuteFlowRequest) GetFlowInputs() *types.Struct

func (*ExecuteFlowRequest) GetInstanceMap 

func (m *ExecuteFlowRequest) GetInstanceMap() *types.Struct

func (*ExecuteFlowRequest) GetMetadata 

func (m *ExecuteFlowRequest) GetMetadata() *ExecuteFlowRequest_Metadata

func (*ExecuteFlowRequest) GetName 

func (m *ExecuteFlowRequest) GetName() string

func (*ExecuteFlowRequest) GetNeedNotify 

func (m *ExecuteFlowRequest) GetNeedNotify() bool

func (*ExecuteFlowRequest) GetParentTaskId 

func (m *ExecuteFlowRequest) GetParentTaskId() string

func (*ExecuteFlowRequest) GetTags 

func (m *ExecuteFlowRequest) GetTags() []string

func (*ExecuteFlowRequest) GetVersion 

func (m *ExecuteFlowRequest) GetVersion() int32

func (*ExecuteFlowRequest) ProtoMessage 

func (*ExecuteFlowRequest) ProtoMessage()

func (*ExecuteFlowRequest) Reset 

func (m *ExecuteFlowRequest) Reset()

func (*ExecuteFlowRequest) String 

func (m *ExecuteFlowRequest) String() string

func (*ExecuteFlowRequest) Validate 

func (this *ExecuteFlowRequest) Validate() error

func (*ExecuteFlowRequest) XXX_DiscardUnknown 

func (m *ExecuteFlowRequest) XXX_DiscardUnknown()

func (*ExecuteFlowRequest) XXX_Marshal 

func (m *ExecuteFlowRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ExecuteFlowRequest) XXX_Merge 

func (m *ExecuteFlowRequest) XXX_Merge(src proto.Message)

func (*ExecuteFlowRequest) XXX_Size 

func (m *ExecuteFlowRequest) XXX_Size() int

func (*ExecuteFlowRequest) XXX_Unmarshal 

func (m *ExecuteFlowRequest) XXX_Unmarshal(b []byte) error

type ExecuteFlowRequest_Metadata 

type ExecuteFlowRequest_Metadata struct {
	//
	//环境
	Type string `protobuf:"bytes,1,opt,name=type,proto3" json:"type" form:"type"`
	//
	//描述
	Desc                 string   `protobuf:"bytes,2,opt,name=desc,proto3" json:"desc" form:"desc"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ExecuteFlowRequest_Metadata) Descriptor 

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

func (*ExecuteFlowRequest_Metadata) GetDesc 

func (m *ExecuteFlowRequest_Metadata) GetDesc() string

func (*ExecuteFlowRequest_Metadata) GetType 

func (m *ExecuteFlowRequest_Metadata) GetType() string

func (*ExecuteFlowRequest_Metadata) ProtoMessage 

func (*ExecuteFlowRequest_Metadata) ProtoMessage()

func (*ExecuteFlowRequest_Metadata) Reset 

func (m *ExecuteFlowRequest_Metadata) Reset()

func (*ExecuteFlowRequest_Metadata) String 

func (m *ExecuteFlowRequest_Metadata) String() string

func (*ExecuteFlowRequest_Metadata) Validate 

func (this *ExecuteFlowRequest_Metadata) Validate() error

func (*ExecuteFlowRequest_Metadata) XXX_DiscardUnknown 

func (m *ExecuteFlowRequest_Metadata) XXX_DiscardUnknown()

func (*ExecuteFlowRequest_Metadata) XXX_Marshal 

func (m *ExecuteFlowRequest_Metadata) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ExecuteFlowRequest_Metadata) XXX_Merge 

func (m *ExecuteFlowRequest_Metadata) XXX_Merge(src proto.Message)

func (*ExecuteFlowRequest_Metadata) XXX_Size 

func (m *ExecuteFlowRequest_Metadata) XXX_Size() int

func (*ExecuteFlowRequest_Metadata) XXX_Unmarshal 

func (m *ExecuteFlowRequest_Metadata) XXX_Unmarshal(b []byte) error

type ExecuteFlowResponse 

type ExecuteFlowResponse struct {
	//
	//流程任务ID
	TaskId               string   `protobuf:"bytes,1,opt,name=taskId,proto3" json:"taskId" form:"taskId"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

ExecuteFlow返回

func (*ExecuteFlowResponse) Descriptor 

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

func (*ExecuteFlowResponse) GetTaskId 

func (m *ExecuteFlowResponse) GetTaskId() string

func (*ExecuteFlowResponse) ProtoMessage 

func (*ExecuteFlowResponse) ProtoMessage()

func (*ExecuteFlowResponse) Reset 

func (m *ExecuteFlowResponse) Reset()

func (*ExecuteFlowResponse) String 

func (m *ExecuteFlowResponse) String() string

func (*ExecuteFlowResponse) Validate 

func (this *ExecuteFlowResponse) Validate() error

func (*ExecuteFlowResponse) XXX_DiscardUnknown 

func (m *ExecuteFlowResponse) XXX_DiscardUnknown()

func (*ExecuteFlowResponse) XXX_Marshal 

func (m *ExecuteFlowResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ExecuteFlowResponse) XXX_Merge 

func (m *ExecuteFlowResponse) XXX_Merge(src proto.Message)

func (*ExecuteFlowResponse) XXX_Size 

func (m *ExecuteFlowResponse) XXX_Size() int

func (*ExecuteFlowResponse) XXX_Unmarshal 

func (m *ExecuteFlowResponse) XXX_Unmarshal(b []byte) error

type ExecuteFlowResponseWrapper 

type ExecuteFlowResponseWrapper struct {
	//
	//返回码
	Code int32 `protobuf:"varint,1,opt,name=code,proto3" json:"code" form:"code"`
	//
	//返回码解释
	CodeExplain string `protobuf:"bytes,2,opt,name=codeExplain,proto3" json:"codeExplain" form:"codeExplain"`
	//
	//错误详情
	Error string `protobuf:"bytes,3,opt,name=error,proto3" json:"error" form:"error"`
	//
	//返回数据
	Data                 *ExecuteFlowResponse `protobuf:"bytes,4,opt,name=data,proto3" json:"data" form:"data"`
	XXX_NoUnkeyedLiteral struct{}             `json:"-"`
	XXX_unrecognized     []byte               `json:"-"`
	XXX_sizecache        int32                `json:"-"`
}

ExecuteFlowApi返回

func (*ExecuteFlowResponseWrapper) Descriptor 

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

func (*ExecuteFlowResponseWrapper) GetCode 

func (m *ExecuteFlowResponseWrapper) GetCode() int32

func (*ExecuteFlowResponseWrapper) GetCodeExplain 

func (m *ExecuteFlowResponseWrapper) GetCodeExplain() string

func (*ExecuteFlowResponseWrapper) GetData 

func (m *ExecuteFlowResponseWrapper) GetData() *ExecuteFlowResponse

func (*ExecuteFlowResponseWrapper) GetError 

func (m *ExecuteFlowResponseWrapper) GetError() string

func (*ExecuteFlowResponseWrapper) ProtoMessage 

func (*ExecuteFlowResponseWrapper) ProtoMessage()

func (*ExecuteFlowResponseWrapper) Reset 

func (m *ExecuteFlowResponseWrapper) Reset()

func (*ExecuteFlowResponseWrapper) String 

func (m *ExecuteFlowResponseWrapper) String() string

func (*ExecuteFlowResponseWrapper) Validate 

func (this *ExecuteFlowResponseWrapper) Validate() error

func (*ExecuteFlowResponseWrapper) XXX_DiscardUnknown 

func (m *ExecuteFlowResponseWrapper) XXX_DiscardUnknown()

func (*ExecuteFlowResponseWrapper) XXX_Marshal 

func (m *ExecuteFlowResponseWrapper) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ExecuteFlowResponseWrapper) XXX_Merge 

func (m *ExecuteFlowResponseWrapper) XXX_Merge(src proto.Message)

func (*ExecuteFlowResponseWrapper) XXX_Size 

func (m *ExecuteFlowResponseWrapper) XXX_Size() int

func (*ExecuteFlowResponseWrapper) XXX_Unmarshal 

func (m *ExecuteFlowResponseWrapper) XXX_Unmarshal(b []byte) error

type GetFlowResultRequest 

type GetFlowResultRequest struct {
	//
	//流程执行任务ID
	TaskId               string   `protobuf:"bytes,1,opt,name=taskId,proto3" json:"taskId" form:"taskId"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

GetFlowResult请求

func (*GetFlowResultRequest) Descriptor 

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

func (*GetFlowResultRequest) GetTaskId 

func (m *GetFlowResultRequest) GetTaskId() string

func (*GetFlowResultRequest) ProtoMessage 

func (*GetFlowResultRequest) ProtoMessage()

func (*GetFlowResultRequest) Reset 

func (m *GetFlowResultRequest) Reset()

func (*GetFlowResultRequest) String 

func (m *GetFlowResultRequest) String() string

func (*GetFlowResultRequest) Validate 

func (this *GetFlowResultRequest) Validate() error

func (*GetFlowResultRequest) XXX_DiscardUnknown 

func (m *GetFlowResultRequest) XXX_DiscardUnknown()

func (*GetFlowResultRequest) XXX_Marshal 

func (m *GetFlowResultRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GetFlowResultRequest) XXX_Merge 

func (m *GetFlowResultRequest) XXX_Merge(src proto.Message)

func (*GetFlowResultRequest) XXX_Size 

func (m *GetFlowResultRequest) XXX_Size() int

func (*GetFlowResultRequest) XXX_Unmarshal 

func (m *GetFlowResultRequest) XXX_Unmarshal(b []byte) error

type GetFlowResultResponseWrapper 

type GetFlowResultResponseWrapper struct {
	//
	//返回码
	Code int32 `protobuf:"varint,1,opt,name=code,proto3" json:"code" form:"code"`
	//
	//返回码解释
	CodeExplain string `protobuf:"bytes,2,opt,name=codeExplain,proto3" json:"codeExplain" form:"codeExplain"`
	//
	//错误详情
	Error string `protobuf:"bytes,3,opt,name=error,proto3" json:"error" form:"error"`
	//
	//返回数据
	Data                 *flow.FlowInstance `protobuf:"bytes,4,opt,name=data,proto3" json:"data" form:"data"`
	XXX_NoUnkeyedLiteral struct{}           `json:"-"`
	XXX_unrecognized     []byte             `json:"-"`
	XXX_sizecache        int32              `json:"-"`
}

GetFlowResultApi返回

func (*GetFlowResultResponseWrapper) Descriptor 

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

func (*GetFlowResultResponseWrapper) GetCode 

func (m *GetFlowResultResponseWrapper) GetCode() int32

func (*GetFlowResultResponseWrapper) GetCodeExplain 

func (m *GetFlowResultResponseWrapper) GetCodeExplain() string

func (*GetFlowResultResponseWrapper) GetData 

func (m *GetFlowResultResponseWrapper) GetData() *flow.FlowInstance

func (*GetFlowResultResponseWrapper) GetError 

func (m *GetFlowResultResponseWrapper) GetError() string

func (*GetFlowResultResponseWrapper) ProtoMessage 

func (*GetFlowResultResponseWrapper) ProtoMessage()

func (*GetFlowResultResponseWrapper) Reset 

func (m *GetFlowResultResponseWrapper) Reset()

func (*GetFlowResultResponseWrapper) String 

func (m *GetFlowResultResponseWrapper) String() string

func (*GetFlowResultResponseWrapper) Validate 

func (this *GetFlowResultResponseWrapper) Validate() error

func (*GetFlowResultResponseWrapper) XXX_DiscardUnknown 

func (m *GetFlowResultResponseWrapper) XXX_DiscardUnknown()

func (*GetFlowResultResponseWrapper) XXX_Marshal 

func (m *GetFlowResultResponseWrapper) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GetFlowResultResponseWrapper) XXX_Merge 

func (m *GetFlowResultResponseWrapper) XXX_Merge(src proto.Message)

func (*GetFlowResultResponseWrapper) XXX_Size 

func (m *GetFlowResultResponseWrapper) XXX_Size() int

func (*GetFlowResultResponseWrapper) XXX_Unmarshal 

func (m *GetFlowResultResponseWrapper) XXX_Unmarshal(b []byte) error

type RetryStepRequest 

type RetryStepRequest struct {
	//
	//任务ID
	TaskId string `protobuf:"bytes,1,opt,name=taskId,proto3" json:"taskId" form:"taskId"`
	//
	//步骤ID
	StepId               int32    `protobuf:"varint,2,opt,name=stepId,proto3" json:"stepId" form:"stepId"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

RetryStep请求

func (*RetryStepRequest) Descriptor 

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

func (*RetryStepRequest) GetStepId 

func (m *RetryStepRequest) GetStepId() int32

func (*RetryStepRequest) GetTaskId 

func (m *RetryStepRequest) GetTaskId() string

func (*RetryStepRequest) ProtoMessage 

func (*RetryStepRequest) ProtoMessage()

func (*RetryStepRequest) Reset 

func (m *RetryStepRequest) Reset()

func (*RetryStepRequest) String 

func (m *RetryStepRequest) String() string

func (*RetryStepRequest) Validate 

func (this *RetryStepRequest) Validate() error

func (*RetryStepRequest) XXX_DiscardUnknown 

func (m *RetryStepRequest) XXX_DiscardUnknown()

func (*RetryStepRequest) XXX_Marshal 

func (m *RetryStepRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*RetryStepRequest) XXX_Merge 

func (m *RetryStepRequest) XXX_Merge(src proto.Message)

func (*RetryStepRequest) XXX_Size 

func (m *RetryStepRequest) XXX_Size() int

func (*RetryStepRequest) XXX_Unmarshal 

func (m *RetryStepRequest) XXX_Unmarshal(b []byte) error

type RetryStepResponse 

type RetryStepResponse struct {
	//
	//流程任务ID
	TaskId string `protobuf:"bytes,1,opt,name=taskId,proto3" json:"taskId" form:"taskId"`
	//
	//流程步骤ID
	StepId               int32    `protobuf:"varint,2,opt,name=stepId,proto3" json:"stepId" form:"stepId"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

RetryStep返回

func (*RetryStepResponse) Descriptor 

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

func (*RetryStepResponse) GetStepId 

func (m *RetryStepResponse) GetStepId() int32

func (*RetryStepResponse) GetTaskId 

func (m *RetryStepResponse) GetTaskId() string

func (*RetryStepResponse) ProtoMessage 

func (*RetryStepResponse) ProtoMessage()

func (*RetryStepResponse) Reset 

func (m *RetryStepResponse) Reset()

func (*RetryStepResponse) String 

func (m *RetryStepResponse) String() string

func (*RetryStepResponse) Validate 

func (this *RetryStepResponse) Validate() error

func (*RetryStepResponse) XXX_DiscardUnknown 

func (m *RetryStepResponse) XXX_DiscardUnknown()

func (*RetryStepResponse) XXX_Marshal 

func (m *RetryStepResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*RetryStepResponse) XXX_Merge 

func (m *RetryStepResponse) XXX_Merge(src proto.Message)

func (*RetryStepResponse) XXX_Size 

func (m *RetryStepResponse) XXX_Size() int

func (*RetryStepResponse) XXX_Unmarshal 

func (m *RetryStepResponse) XXX_Unmarshal(b []byte) error

type RetryStepResponseWrapper 

type RetryStepResponseWrapper struct {
	//
	//返回码
	Code int32 `protobuf:"varint,1,opt,name=code,proto3" json:"code" form:"code"`
	//
	//返回码解释
	CodeExplain string `protobuf:"bytes,2,opt,name=codeExplain,proto3" json:"codeExplain" form:"codeExplain"`
	//
	//错误详情
	Error string `protobuf:"bytes,3,opt,name=error,proto3" json:"error" form:"error"`
	//
	//返回数据
	Data                 *RetryStepResponse `protobuf:"bytes,4,opt,name=data,proto3" json:"data" form:"data"`
	XXX_NoUnkeyedLiteral struct{}           `json:"-"`
	XXX_unrecognized     []byte             `json:"-"`
	XXX_sizecache        int32              `json:"-"`
}

RetryStepApi返回

func (*RetryStepResponseWrapper) Descriptor 

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

func (*RetryStepResponseWrapper) GetCode 

func (m *RetryStepResponseWrapper) GetCode() int32

func (*RetryStepResponseWrapper) GetCodeExplain 

func (m *RetryStepResponseWrapper) GetCodeExplain() string

func (*RetryStepResponseWrapper) GetData 

func (m *RetryStepResponseWrapper) GetData() *RetryStepResponse

func (*RetryStepResponseWrapper) GetError 

func (m *RetryStepResponseWrapper) GetError() string

func (*RetryStepResponseWrapper) ProtoMessage 

func (*RetryStepResponseWrapper) ProtoMessage()

func (*RetryStepResponseWrapper) Reset 

func (m *RetryStepResponseWrapper) Reset()

func (*RetryStepResponseWrapper) String 

func (m *RetryStepResponseWrapper) String() string

func (*RetryStepResponseWrapper) Validate 

func (this *RetryStepResponseWrapper) Validate() error

func (*RetryStepResponseWrapper) XXX_DiscardUnknown 

func (m *RetryStepResponseWrapper) XXX_DiscardUnknown()

func (*RetryStepResponseWrapper) XXX_Marshal 

func (m *RetryStepResponseWrapper) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*RetryStepResponseWrapper) XXX_Merge 

func (m *RetryStepResponseWrapper) XXX_Merge(src proto.Message)

func (*RetryStepResponseWrapper) XXX_Size 

func (m *RetryStepResponseWrapper) XXX_Size() int

func (*RetryStepResponseWrapper) XXX_Unmarshal 

func (m *RetryStepResponseWrapper) XXX_Unmarshal(b []byte) error

type Service 

type Service interface {
	ExecuteFlow(context.Context, *ExecuteFlowRequest) (*ExecuteFlowResponse, error)
	GetFlowResult(context.Context, *GetFlowResultRequest) (*flow.FlowInstance, error)
	RetryStep(context.Context, *RetryStepRequest) (*RetryStepResponse, error)
}

Service is the server API for execute service.

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.