api_v1

package
v0.0.1-beta Latest Latest
Warning

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

 Go to latest Published: Oct 24, 2022 License: Apache-2.0 Imports: 11 Imported by: 7

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	TaskResult_Status_name = map[int32]string{
		0: "SUCCESS",
		1: "FAIL",
	}
	TaskResult_Status_value = map[string]int32{
		"SUCCESS": 0,
		"FAIL":    1,
	}
)

Enum value maps for TaskResult_Status.

View Source 
var File_api_v1_flow_proto protoreflect.FileDescriptor
View Source 
var TaskService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "TaskService",
	HandlerType: (*TaskServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "SaveTaskDef",
			Handler:    _TaskService_SaveTaskDef_Handler,
		},
		{
			MethodName: "Poll",
			Handler:    _TaskService_Poll_Handler,
		},
		{
			MethodName: "Push",
			Handler:    _TaskService_Push_Handler,
		},
		{
			MethodName: "GetServers",
			Handler:    _TaskService_GetServers_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "api/v1/flow.proto",
}

TaskService_ServiceDesc is the grpc.ServiceDesc for TaskService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

Functions

func RegisterTaskServiceServer 

func RegisterTaskServiceServer(s grpc.ServiceRegistrar, srv TaskServiceServer)

Types

type GetServersRequest 

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

func (*GetServersRequest) Descriptor deprecated 

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

Deprecated: Use GetServersRequest.ProtoReflect.Descriptor instead.

func (*GetServersRequest) ProtoMessage 

func (*GetServersRequest) ProtoMessage()

func (*GetServersRequest) ProtoReflect 

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

func (*GetServersRequest) Reset 

func (x *GetServersRequest) Reset()

func (*GetServersRequest) String 

func (x *GetServersRequest) String() string

type GetServersResponse 

type GetServersResponse struct {
	Servers []*Server `protobuf:"bytes,1,rep,name=servers,proto3" json:"servers,omitempty"`
	// contains filtered or unexported fields
}

func (*GetServersResponse) Descriptor deprecated 

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

Deprecated: Use GetServersResponse.ProtoReflect.Descriptor instead.

func (*GetServersResponse) GetServers 

func (x *GetServersResponse) GetServers() []*Server

func (*GetServersResponse) ProtoMessage 

func (*GetServersResponse) ProtoMessage()

func (*GetServersResponse) ProtoReflect 

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

func (*GetServersResponse) Reset 

func (x *GetServersResponse) Reset()

func (*GetServersResponse) String 

func (x *GetServersResponse) String() string

type Server 

type Server struct {
	Id      string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	RpcAddr string `protobuf:"bytes,2,opt,name=rpc_addr,json=rpcAddr,proto3" json:"rpc_addr,omitempty"`
	// contains filtered or unexported fields
}

func (*Server) Descriptor deprecated 

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

Deprecated: Use Server.ProtoReflect.Descriptor instead.

func (*Server) GetId 

func (x *Server) GetId() string

func (*Server) GetRpcAddr 

func (x *Server) GetRpcAddr() string

func (*Server) ProtoMessage 

func (*Server) ProtoMessage()

func (*Server) ProtoReflect 

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

func (*Server) Reset 

func (x *Server) Reset()

func (*Server) String 

func (x *Server) String() string

type StorageLayerError 

type StorageLayerError struct{}

func (StorageLayerError) Error 

func (e StorageLayerError) Error() string

func (StorageLayerError) GRPCStatus 

func (e StorageLayerError) GRPCStatus() *status.Status

type Task 

type Task struct {
	WorkflowName string                     `protobuf:"bytes,1,opt,name=workflowName,proto3" json:"workflowName,omitempty"`
	FlowId       string                     `protobuf:"bytes,2,opt,name=flowId,proto3" json:"flowId,omitempty"`
	Data         map[string]*structpb.Value `` /* 149-byte string literal not displayed */
	ActionId     int32                      `protobuf:"varint,4,opt,name=actionId,proto3" json:"actionId,omitempty"`
	TaskName     string                     `protobuf:"bytes,5,opt,name=taskName,proto3" json:"taskName,omitempty"`
	RetryCount   int32                      `protobuf:"varint,6,opt,name=retryCount,proto3" json:"retryCount,omitempty"`
	// contains filtered or unexported fields
}

func (*Task) Descriptor deprecated 

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

Deprecated: Use Task.ProtoReflect.Descriptor instead.

func (*Task) GetActionId 

func (x *Task) GetActionId() int32

func (*Task) GetData 

func (x *Task) GetData() map[string]*structpb.Value

func (*Task) GetFlowId 

func (x *Task) GetFlowId() string

func (*Task) GetRetryCount 

func (x *Task) GetRetryCount() int32

func (*Task) GetTaskName 

func (x *Task) GetTaskName() string

func (*Task) GetWorkflowName 

func (x *Task) GetWorkflowName() string

func (*Task) ProtoMessage 

func (*Task) ProtoMessage()

func (*Task) ProtoReflect 

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

func (*Task) Reset 

func (x *Task) Reset()

func (*Task) String 

func (x *Task) String() string

type TaskDef 

type TaskDef struct {
	Name              string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	RetryCount        int32  `protobuf:"varint,2,opt,name=retryCount,proto3" json:"retryCount,omitempty"`
	RetryAfterSeconds int32  `protobuf:"varint,3,opt,name=retryAfterSeconds,proto3" json:"retryAfterSeconds,omitempty"`
	RetryPolicy       string `protobuf:"bytes,4,opt,name=retryPolicy,proto3" json:"retryPolicy,omitempty"`
	TimeoutSeconds    int32  `protobuf:"varint,5,opt,name=timeoutSeconds,proto3" json:"timeoutSeconds,omitempty"`
	// contains filtered or unexported fields
}

func (*TaskDef) Descriptor deprecated 

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

Deprecated: Use TaskDef.ProtoReflect.Descriptor instead.

func (*TaskDef) GetName 

func (x *TaskDef) GetName() string

func (*TaskDef) GetRetryAfterSeconds 

func (x *TaskDef) GetRetryAfterSeconds() int32

func (*TaskDef) GetRetryCount 

func (x *TaskDef) GetRetryCount() int32

func (*TaskDef) GetRetryPolicy 

func (x *TaskDef) GetRetryPolicy() string

func (*TaskDef) GetTimeoutSeconds 

func (x *TaskDef) GetTimeoutSeconds() int32

func (*TaskDef) ProtoMessage 

func (*TaskDef) ProtoMessage()

func (*TaskDef) ProtoReflect 

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

func (*TaskDef) Reset 

func (x *TaskDef) Reset()

func (*TaskDef) String 

func (x *TaskDef) String() string

type TaskDefSaveResponse 

type TaskDefSaveResponse struct {
	Status bool `protobuf:"varint,1,opt,name=status,proto3" json:"status,omitempty"`
	// contains filtered or unexported fields
}

func (*TaskDefSaveResponse) Descriptor deprecated 

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

Deprecated: Use TaskDefSaveResponse.ProtoReflect.Descriptor instead.

func (*TaskDefSaveResponse) GetStatus 

func (x *TaskDefSaveResponse) GetStatus() bool

func (*TaskDefSaveResponse) ProtoMessage 

func (*TaskDefSaveResponse) ProtoMessage()

func (*TaskDefSaveResponse) ProtoReflect 

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

func (*TaskDefSaveResponse) Reset 

func (x *TaskDefSaveResponse) Reset()

func (*TaskDefSaveResponse) String 

func (x *TaskDefSaveResponse) String() string

type TaskPollRequest 

type TaskPollRequest struct {
	TaskType  string `protobuf:"bytes,1,opt,name=taskType,proto3" json:"taskType,omitempty"`
	BatchSize int32  `protobuf:"varint,2,opt,name=batchSize,proto3" json:"batchSize,omitempty"`
	// contains filtered or unexported fields
}

func (*TaskPollRequest) Descriptor deprecated 

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

Deprecated: Use TaskPollRequest.ProtoReflect.Descriptor instead.

func (*TaskPollRequest) GetBatchSize 

func (x *TaskPollRequest) GetBatchSize() int32

func (*TaskPollRequest) GetTaskType 

func (x *TaskPollRequest) GetTaskType() string

func (*TaskPollRequest) ProtoMessage 

func (*TaskPollRequest) ProtoMessage()

func (*TaskPollRequest) ProtoReflect 

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

func (*TaskPollRequest) Reset 

func (x *TaskPollRequest) Reset()

func (*TaskPollRequest) String 

func (x *TaskPollRequest) String() string

type TaskResult 

type TaskResult struct {
	WorkflowName string                     `protobuf:"bytes,1,opt,name=workflowName,proto3" json:"workflowName,omitempty"`
	TaskName     string                     `protobuf:"bytes,2,opt,name=taskName,proto3" json:"taskName,omitempty"`
	FlowId       string                     `protobuf:"bytes,3,opt,name=flowId,proto3" json:"flowId,omitempty"`
	ActionId     int32                      `protobuf:"varint,4,opt,name=actionId,proto3" json:"actionId,omitempty"`
	Data         map[string]*structpb.Value `` /* 149-byte string literal not displayed */
	Status       TaskResult_Status          `protobuf:"varint,6,opt,name=status,proto3,enum=TaskResult_Status" json:"status,omitempty"`
	RetryCount   int32                      `protobuf:"varint,7,opt,name=retryCount,proto3" json:"retryCount,omitempty"`
	// contains filtered or unexported fields
}

func (*TaskResult) Descriptor deprecated 

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

Deprecated: Use TaskResult.ProtoReflect.Descriptor instead.

func (*TaskResult) GetActionId 

func (x *TaskResult) GetActionId() int32

func (*TaskResult) GetData 

func (x *TaskResult) GetData() map[string]*structpb.Value

func (*TaskResult) GetFlowId 

func (x *TaskResult) GetFlowId() string

func (*TaskResult) GetRetryCount 

func (x *TaskResult) GetRetryCount() int32

func (*TaskResult) GetStatus 

func (x *TaskResult) GetStatus() TaskResult_Status

func (*TaskResult) GetTaskName 

func (x *TaskResult) GetTaskName() string

func (*TaskResult) GetWorkflowName 

func (x *TaskResult) GetWorkflowName() string

func (*TaskResult) ProtoMessage 

func (*TaskResult) ProtoMessage()

func (*TaskResult) ProtoReflect 

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

func (*TaskResult) Reset 

func (x *TaskResult) Reset()

func (*TaskResult) String 

func (x *TaskResult) String() string

type TaskResultPushResponse 

type TaskResultPushResponse struct {
	Status bool `protobuf:"varint,1,opt,name=status,proto3" json:"status,omitempty"`
	// contains filtered or unexported fields
}

func (*TaskResultPushResponse) Descriptor deprecated 

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

Deprecated: Use TaskResultPushResponse.ProtoReflect.Descriptor instead.

func (*TaskResultPushResponse) GetStatus 

func (x *TaskResultPushResponse) GetStatus() bool

func (*TaskResultPushResponse) ProtoMessage 

func (*TaskResultPushResponse) ProtoMessage()

func (*TaskResultPushResponse) ProtoReflect 

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

func (*TaskResultPushResponse) Reset 

func (x *TaskResultPushResponse) Reset()

func (*TaskResultPushResponse) String 

func (x *TaskResultPushResponse) String() string

type TaskResult_Status 

type TaskResult_Status int32
const (
	TaskResult_SUCCESS TaskResult_Status = 0
	TaskResult_FAIL    TaskResult_Status = 1
)

func (TaskResult_Status) Descriptor 

func (TaskResult_Status) Descriptor() protoreflect.EnumDescriptor

func (TaskResult_Status) Enum 

func (x TaskResult_Status) Enum() *TaskResult_Status

func (TaskResult_Status) EnumDescriptor deprecated 

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

Deprecated: Use TaskResult_Status.Descriptor instead.

func (TaskResult_Status) Number 

func (x TaskResult_Status) Number() protoreflect.EnumNumber

func (TaskResult_Status) String 

func (x TaskResult_Status) String() string

func (TaskResult_Status) Type 

func (TaskResult_Status) Type() protoreflect.EnumType

type TaskServiceClient 

type TaskServiceClient interface {
	SaveTaskDef(ctx context.Context, in *TaskDef, opts ...grpc.CallOption) (*TaskDefSaveResponse, error)
	Poll(ctx context.Context, in *TaskPollRequest, opts ...grpc.CallOption) (*Tasks, error)
	Push(ctx context.Context, in *TaskResult, opts ...grpc.CallOption) (*TaskResultPushResponse, error)
	GetServers(ctx context.Context, in *GetServersRequest, opts ...grpc.CallOption) (*GetServersResponse, error)
}

TaskServiceClient is the client API for TaskService service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewTaskServiceClient 

func NewTaskServiceClient(cc grpc.ClientConnInterface) TaskServiceClient

type TaskServiceServer 

type TaskServiceServer interface {
	SaveTaskDef(context.Context, *TaskDef) (*TaskDefSaveResponse, error)
	Poll(context.Context, *TaskPollRequest) (*Tasks, error)
	Push(context.Context, *TaskResult) (*TaskResultPushResponse, error)
	GetServers(context.Context, *GetServersRequest) (*GetServersResponse, error)
	// contains filtered or unexported methods
}

TaskServiceServer is the server API for TaskService service. All implementations must embed UnimplementedTaskServiceServer for forward compatibility

type Tasks 

type Tasks struct {
	Tasks []*Task `protobuf:"bytes,1,rep,name=tasks,proto3" json:"tasks,omitempty"`
	// contains filtered or unexported fields
}

func (*Tasks) Descriptor deprecated 

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

Deprecated: Use Tasks.ProtoReflect.Descriptor instead.

func (*Tasks) GetTasks 

func (x *Tasks) GetTasks() []*Task

func (*Tasks) ProtoMessage 

func (*Tasks) ProtoMessage()

func (*Tasks) ProtoReflect 

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

func (*Tasks) Reset 

func (x *Tasks) Reset()

func (*Tasks) String 

func (x *Tasks) String() string

type UnimplementedTaskServiceServer 

type UnimplementedTaskServiceServer struct {
}

UnimplementedTaskServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedTaskServiceServer) GetServers 

func (UnimplementedTaskServiceServer) GetServers(context.Context, *GetServersRequest) (*GetServersResponse, error)

func (UnimplementedTaskServiceServer) Poll 

func (UnimplementedTaskServiceServer) Poll(context.Context, *TaskPollRequest) (*Tasks, error)

func (UnimplementedTaskServiceServer) Push 

func (UnimplementedTaskServiceServer) Push(context.Context, *TaskResult) (*TaskResultPushResponse, error)

func (UnimplementedTaskServiceServer) SaveTaskDef 

func (UnimplementedTaskServiceServer) SaveTaskDef(context.Context, *TaskDef) (*TaskDefSaveResponse, error)

type UnsafeTaskServiceServer 

type UnsafeTaskServiceServer interface {
	// contains filtered or unexported methods
}

UnsafeTaskServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to TaskServiceServer will result in compilation errors.

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.