flexletpb

package
v0.1.1 Latest Latest
Warning

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

 Go to latest Published: Sep 2, 2022 License: Apache-2.0 Imports: 9 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var File_internal_flexletpb_flexlet_proto protoreflect.FileDescriptor
View Source 
var File_internal_flexletpb_flexlet_service_proto protoreflect.FileDescriptor
View Source 
var FlexletService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "flex.FlexletService",
	HandlerType: (*FlexletServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "TakeTask",
			Handler:    _FlexletService_TakeTask_Handler,
		},
		{
			MethodName: "UpdateTask",
			Handler:    _FlexletService_UpdateTask_Handler,
		},
		{
			MethodName: "FinishTask",
			Handler:    _FlexletService_FinishTask_Handler,
		},
		{
			MethodName: "UpdateFlexlet",
			Handler:    _FlexletService_UpdateFlexlet_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "internal/flexletpb/flexlet_service.proto",
}

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

Functions

func RegisterFlexletServiceServer 

func RegisterFlexletServiceServer(s grpc.ServiceRegistrar, srv FlexletServiceServer)

Types

type FinishTaskRequest 

type FinishTaskRequest struct {
	Ref       *TaskRef         `protobuf:"bytes,1,opt,name=ref,proto3" json:"ref,omitempty"`
	Result    *flex.TaskResult `protobuf:"bytes,2,opt,name=result,proto3" json:"result,omitempty"`
	NeedRetry bool             `protobuf:"varint,3,opt,name=need_retry,json=needRetry,proto3" json:"need_retry,omitempty"`
	// contains filtered or unexported fields
}

func (*FinishTaskRequest) Descriptor deprecated 

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

Deprecated: Use FinishTaskRequest.ProtoReflect.Descriptor instead.

func (*FinishTaskRequest) GetNeedRetry 

func (x *FinishTaskRequest) GetNeedRetry() bool

func (*FinishTaskRequest) GetRef 

func (x *FinishTaskRequest) GetRef() *TaskRef

func (*FinishTaskRequest) GetResult 

func (x *FinishTaskRequest) GetResult() *flex.TaskResult

func (*FinishTaskRequest) ProtoMessage 

func (*FinishTaskRequest) ProtoMessage()

func (*FinishTaskRequest) ProtoReflect 

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

func (*FinishTaskRequest) Reset 

func (x *FinishTaskRequest) Reset()

func (*FinishTaskRequest) String 

func (x *FinishTaskRequest) String() string

type FinishTaskResponse 

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

func (*FinishTaskResponse) Descriptor deprecated 

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

Deprecated: Use FinishTaskResponse.ProtoReflect.Descriptor instead.

func (*FinishTaskResponse) ProtoMessage 

func (*FinishTaskResponse) ProtoMessage()

func (*FinishTaskResponse) ProtoReflect 

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

func (*FinishTaskResponse) Reset 

func (x *FinishTaskResponse) Reset()

func (*FinishTaskResponse) String 

func (x *FinishTaskResponse) String() string

type FlexletServiceClient 

type FlexletServiceClient interface {
	TakeTask(ctx context.Context, in *TakeTaskRequest, opts ...grpc.CallOption) (*TakeTaskResponse, error)
	UpdateTask(ctx context.Context, in *UpdateTaskRequest, opts ...grpc.CallOption) (*UpdateTaskResponse, error)
	FinishTask(ctx context.Context, in *FinishTaskRequest, opts ...grpc.CallOption) (*FinishTaskResponse, error)
	UpdateFlexlet(ctx context.Context, in *UpdateFlexletRequest, opts ...grpc.CallOption) (*UpdateFlexletResponse, error)
}

FlexletServiceClient is the client API for FlexletService 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 NewFlexletServiceClient 

func NewFlexletServiceClient(cc grpc.ClientConnInterface) FlexletServiceClient

type FlexletServiceServer 

type FlexletServiceServer interface {
	TakeTask(context.Context, *TakeTaskRequest) (*TakeTaskResponse, error)
	UpdateTask(context.Context, *UpdateTaskRequest) (*UpdateTaskResponse, error)
	FinishTask(context.Context, *FinishTaskRequest) (*FinishTaskResponse, error)
	UpdateFlexlet(context.Context, *UpdateFlexletRequest) (*UpdateFlexletResponse, error)
	// contains filtered or unexported methods
}

FlexletServiceServer is the server API for FlexletService service. All implementations must embed UnimplementedFlexletServiceServer for forward compatibility

type TakeTaskRequest 

type TakeTaskRequest struct {
	FlexletName string `protobuf:"bytes,1,opt,name=flexlet_name,json=flexletName,proto3" json:"flexlet_name,omitempty"`
	Wait        bool   `protobuf:"varint,2,opt,name=wait,proto3" json:"wait,omitempty"`
	// contains filtered or unexported fields
}

func (*TakeTaskRequest) Descriptor deprecated 

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

Deprecated: Use TakeTaskRequest.ProtoReflect.Descriptor instead.

func (*TakeTaskRequest) GetFlexletName 

func (x *TakeTaskRequest) GetFlexletName() string

func (*TakeTaskRequest) GetWait 

func (x *TakeTaskRequest) GetWait() bool

func (*TakeTaskRequest) ProtoMessage 

func (*TakeTaskRequest) ProtoMessage()

func (*TakeTaskRequest) ProtoReflect 

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

func (*TakeTaskRequest) Reset 

func (x *TakeTaskRequest) Reset()

func (*TakeTaskRequest) String 

func (x *TakeTaskRequest) String() string

type TakeTaskResponse 

type TakeTaskResponse struct {
	Task *Task `protobuf:"bytes,1,opt,name=task,proto3" json:"task,omitempty"`
	// contains filtered or unexported fields
}

func (*TakeTaskResponse) Descriptor deprecated 

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

Deprecated: Use TakeTaskResponse.ProtoReflect.Descriptor instead.

func (*TakeTaskResponse) GetTask 

func (x *TakeTaskResponse) GetTask() *Task

func (*TakeTaskResponse) ProtoMessage 

func (*TakeTaskResponse) ProtoMessage()

func (*TakeTaskResponse) ProtoReflect 

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

func (*TakeTaskResponse) Reset 

func (x *TakeTaskResponse) Reset()

func (*TakeTaskResponse) String 

func (x *TakeTaskResponse) String() string

type Task 

type Task struct {
	Ref  *TaskRef  `protobuf:"bytes,1,opt,name=ref,proto3" json:"ref,omitempty"`
	Spec *TaskSpec `protobuf:"bytes,2,opt,name=spec,proto3" json:"spec,omitempty"`
	// contains filtered or unexported fields
}

func (*Task) Descriptor deprecated 

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

Deprecated: Use Task.ProtoReflect.Descriptor instead.

func (*Task) GetRef 

func (x *Task) GetRef() *TaskRef

func (*Task) GetSpec 

func (x *Task) GetSpec() *TaskSpec

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 TaskInputs 

type TaskInputs struct {
	Packages []*TaskPackage `protobuf:"bytes,1,rep,name=packages,proto3" json:"packages,omitempty"`
	// contains filtered or unexported fields
}

func (*TaskInputs) Descriptor deprecated 

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

Deprecated: Use TaskInputs.ProtoReflect.Descriptor instead.

func (*TaskInputs) GetPackages 

func (x *TaskInputs) GetPackages() []*TaskPackage

func (*TaskInputs) ProtoMessage 

func (*TaskInputs) ProtoMessage()

func (*TaskInputs) ProtoReflect 

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

func (*TaskInputs) Reset 

func (x *TaskInputs) Reset()

func (*TaskInputs) String 

func (x *TaskInputs) String() string

type TaskOutputs 

type TaskOutputs struct {
	Stdout *flex.FileLocation `protobuf:"bytes,1,opt,name=stdout,proto3" json:"stdout,omitempty"`
	Stderr *flex.FileLocation `protobuf:"bytes,2,opt,name=stderr,proto3" json:"stderr,omitempty"`
	// contains filtered or unexported fields
}

func (*TaskOutputs) Descriptor deprecated 

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

Deprecated: Use TaskOutputs.ProtoReflect.Descriptor instead.

func (*TaskOutputs) GetStderr 

func (x *TaskOutputs) GetStderr() *flex.FileLocation

func (*TaskOutputs) GetStdout 

func (x *TaskOutputs) GetStdout() *flex.FileLocation

func (*TaskOutputs) ProtoMessage 

func (*TaskOutputs) ProtoMessage()

func (*TaskOutputs) ProtoReflect 

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

func (*TaskOutputs) Reset 

func (x *TaskOutputs) Reset()

func (*TaskOutputs) String 

func (x *TaskOutputs) String() string

type TaskPackage 

type TaskPackage struct {
	Location   *flex.FileLocation `protobuf:"bytes,1,opt,name=location,proto3" json:"location,omitempty"`
	InstallDir string             `protobuf:"bytes,2,opt,name=install_dir,json=installDir,proto3" json:"install_dir,omitempty"`
	// contains filtered or unexported fields
}

func (*TaskPackage) Descriptor deprecated 

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

Deprecated: Use TaskPackage.ProtoReflect.Descriptor instead.

func (*TaskPackage) GetInstallDir 

func (x *TaskPackage) GetInstallDir() string

func (*TaskPackage) GetLocation 

func (x *TaskPackage) GetLocation() *flex.FileLocation

func (*TaskPackage) ProtoMessage 

func (*TaskPackage) ProtoMessage()

func (*TaskPackage) ProtoReflect 

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

func (*TaskPackage) Reset 

func (x *TaskPackage) Reset()

func (*TaskPackage) String 

func (x *TaskPackage) String() string

type TaskRef 

type TaskRef struct {
	TaskId string `protobuf:"bytes,1,opt,name=task_id,json=taskId,proto3" json:"task_id,omitempty"`
	JobId  int64  `protobuf:"varint,2,opt,name=job_id,json=jobId,proto3" json:"job_id,omitempty"`
	// contains filtered or unexported fields
}

func (*TaskRef) Descriptor deprecated 

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

Deprecated: Use TaskRef.ProtoReflect.Descriptor instead.

func (*TaskRef) GetJobId 

func (x *TaskRef) GetJobId() int64

func (*TaskRef) GetTaskId 

func (x *TaskRef) GetTaskId() string

func (*TaskRef) ProtoMessage 

func (*TaskRef) ProtoMessage()

func (*TaskRef) ProtoReflect 

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

func (*TaskRef) Reset 

func (x *TaskRef) Reset()

func (*TaskRef) String 

func (x *TaskRef) String() string

type TaskSpec 

type TaskSpec struct {
	Command *flex.JobCommand `protobuf:"bytes,1,opt,name=command,proto3" json:"command,omitempty"`
	Inputs  *TaskInputs      `protobuf:"bytes,2,opt,name=inputs,proto3" json:"inputs,omitempty"`
	Outputs *TaskOutputs     `protobuf:"bytes,3,opt,name=outputs,proto3" json:"outputs,omitempty"`
	Limits  *flex.JobLimits  `protobuf:"bytes,4,opt,name=limits,proto3" json:"limits,omitempty"`
	// contains filtered or unexported fields
}

func (*TaskSpec) Descriptor deprecated 

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

Deprecated: Use TaskSpec.ProtoReflect.Descriptor instead.

func (*TaskSpec) GetCommand 

func (x *TaskSpec) GetCommand() *flex.JobCommand

func (*TaskSpec) GetInputs 

func (x *TaskSpec) GetInputs() *TaskInputs

func (*TaskSpec) GetLimits 

func (x *TaskSpec) GetLimits() *flex.JobLimits

func (*TaskSpec) GetOutputs 

func (x *TaskSpec) GetOutputs() *TaskOutputs

func (*TaskSpec) ProtoMessage 

func (*TaskSpec) ProtoMessage()

func (*TaskSpec) ProtoReflect 

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

func (*TaskSpec) Reset 

func (x *TaskSpec) Reset()

func (*TaskSpec) String 

func (x *TaskSpec) String() string

type UnimplementedFlexletServiceServer 

type UnimplementedFlexletServiceServer struct {
}

UnimplementedFlexletServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedFlexletServiceServer) FinishTask 

func (UnimplementedFlexletServiceServer) FinishTask(context.Context, *FinishTaskRequest) (*FinishTaskResponse, error)

func (UnimplementedFlexletServiceServer) TakeTask 

func (UnimplementedFlexletServiceServer) TakeTask(context.Context, *TakeTaskRequest) (*TakeTaskResponse, error)

func (UnimplementedFlexletServiceServer) UpdateFlexlet 

func (UnimplementedFlexletServiceServer) UpdateFlexlet(context.Context, *UpdateFlexletRequest) (*UpdateFlexletResponse, error)

func (UnimplementedFlexletServiceServer) UpdateTask 

func (UnimplementedFlexletServiceServer) UpdateTask(context.Context, *UpdateTaskRequest) (*UpdateTaskResponse, error)

type UnsafeFlexletServiceServer 

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

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

type UpdateFlexletRequest 

type UpdateFlexletRequest struct {
	Status *flex.FlexletStatus `protobuf:"bytes,1,opt,name=status,proto3" json:"status,omitempty"`
	// contains filtered or unexported fields
}

func (*UpdateFlexletRequest) Descriptor deprecated 

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

Deprecated: Use UpdateFlexletRequest.ProtoReflect.Descriptor instead.

func (*UpdateFlexletRequest) GetStatus 

func (x *UpdateFlexletRequest) GetStatus() *flex.FlexletStatus

func (*UpdateFlexletRequest) ProtoMessage 

func (*UpdateFlexletRequest) ProtoMessage()

func (*UpdateFlexletRequest) ProtoReflect 

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

func (*UpdateFlexletRequest) Reset 

func (x *UpdateFlexletRequest) Reset()

func (*UpdateFlexletRequest) String 

func (x *UpdateFlexletRequest) String() string

type UpdateFlexletResponse 

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

func (*UpdateFlexletResponse) Descriptor deprecated 

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

Deprecated: Use UpdateFlexletResponse.ProtoReflect.Descriptor instead.

func (*UpdateFlexletResponse) ProtoMessage 

func (*UpdateFlexletResponse) ProtoMessage()

func (*UpdateFlexletResponse) ProtoReflect 

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

func (*UpdateFlexletResponse) Reset 

func (x *UpdateFlexletResponse) Reset()

func (*UpdateFlexletResponse) String 

func (x *UpdateFlexletResponse) String() string

type UpdateTaskRequest 

type UpdateTaskRequest struct {
	Ref *TaskRef `protobuf:"bytes,1,opt,name=ref,proto3" json:"ref,omitempty"`
	// contains filtered or unexported fields
}

func (*UpdateTaskRequest) Descriptor deprecated 

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

Deprecated: Use UpdateTaskRequest.ProtoReflect.Descriptor instead.

func (*UpdateTaskRequest) GetRef 

func (x *UpdateTaskRequest) GetRef() *TaskRef

func (*UpdateTaskRequest) ProtoMessage 

func (*UpdateTaskRequest) ProtoMessage()

func (*UpdateTaskRequest) ProtoReflect 

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

func (*UpdateTaskRequest) Reset 

func (x *UpdateTaskRequest) Reset()

func (*UpdateTaskRequest) String 

func (x *UpdateTaskRequest) String() string

type UpdateTaskResponse 

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

func (*UpdateTaskResponse) Descriptor deprecated 

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

Deprecated: Use UpdateTaskResponse.ProtoReflect.Descriptor instead.

func (*UpdateTaskResponse) ProtoMessage 

func (*UpdateTaskResponse) ProtoMessage()

func (*UpdateTaskResponse) ProtoReflect 

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

func (*UpdateTaskResponse) Reset 

func (x *UpdateTaskResponse) Reset()

func (*UpdateTaskResponse) String 

func (x *UpdateTaskResponse) 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.