api_v1

package
v0.0.0-beta.1 Latest Latest
Warning

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

 Go to latest Published: Jul 25, 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,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "PollStream",
			Handler:       _TaskService_PollStream_Handler,
			ServerStreams: true,
		},
	},
	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 PollError 

type PollError struct {
	QueueName string
}

func (PollError) Error 

func (e PollError) Error() string

func (PollError) GRPCStatus 

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

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"`
	// contains filtered or unexported fields
}

func (*TaskPollRequest) Descriptor deprecated 

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

Deprecated: Use TaskPollRequest.ProtoReflect.Descriptor instead.

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) (*Task, error)
	PollStream(ctx context.Context, in *TaskPollRequest, opts ...grpc.CallOption) (TaskService_PollStreamClient, error)
	Push(ctx context.Context, in *TaskResult, opts ...grpc.CallOption) (*TaskResultPushResponse, 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) (*Task, error)
	PollStream(*TaskPollRequest, TaskService_PollStreamServer) error
	Push(context.Context, *TaskResult) (*TaskResultPushResponse, error)
	// contains filtered or unexported methods
}

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

type TaskService_PollStreamClient 

type TaskService_PollStreamClient interface {
	Recv() (*Task, error)
	grpc.ClientStream
}

type TaskService_PollStreamServer 

type TaskService_PollStreamServer interface {
	Send(*Task) error
	grpc.ServerStream
}

type UnimplementedTaskServiceServer 

type UnimplementedTaskServiceServer struct {
}

UnimplementedTaskServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedTaskServiceServer) Poll 

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

func (UnimplementedTaskServiceServer) PollStream 

func (UnimplementedTaskServiceServer) PollStream(*TaskPollRequest, TaskService_PollStreamServer) 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.