protobuf

package
v1.0.0 Latest Latest
Warning

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

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

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	EnumFileType_name = map[int32]string{
		0: "EFT_UNSPECIFIED",
		1: "EFT_TAR",
	}
	EnumFileType_value = map[string]int32{
		"EFT_UNSPECIFIED": 0,
		"EFT_TAR":         1,
	}
)

Enum value maps for EnumFileType.

View Source 
var (
	EnumFileFetchMethod_name = map[int32]string{
		0: "EFFM_UNSPECIFIED",
		1: "EFFM_HTTP",
		2: "EFFM_GRPC_STREAM",
	}
	EnumFileFetchMethod_value = map[string]int32{
		"EFFM_UNSPECIFIED": 0,
		"EFFM_HTTP":        1,
		"EFFM_GRPC_STREAM": 2,
	}
)

Enum value maps for EnumFileFetchMethod.

View Source 
var (
	EnumFileOperation_name = map[int32]string{
		0: "EFO_UNSPECIFIED",
		1: "EFO_UNTAR",
	}
	EnumFileOperation_value = map[string]int32{
		"EFO_UNSPECIFIED": 0,
		"EFO_UNTAR":       1,
	}
)

Enum value maps for EnumFileOperation.

View Source 
var Engine_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "protobuf.engine",
	HandlerType: (*EngineServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "HeartBeats",
			Handler:    _Engine_HeartBeats_Handler,
		},
		{
			MethodName: "GetNewJob",
			Handler:    _Engine_GetNewJob_Handler,
		},
		{
			MethodName: "PopulateJobResult",
			Handler:    _Engine_PopulateJobResult_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "engine.proto",
}

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

View Source 
var File_engine_proto protoreflect.FileDescriptor
View Source 
var File_job_proto protoreflect.FileDescriptor

Functions

func RegisterEngineServer 

func RegisterEngineServer(s grpc.ServiceRegistrar, srv EngineServer)

Types

type DockerImage 

type DockerImage struct {
	Id  string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Tag string `protobuf:"bytes,2,opt,name=tag,proto3" json:"tag,omitempty"`
	Uri string `protobuf:"bytes,3,opt,name=uri,proto3" json:"uri,omitempty"`
	// contains filtered or unexported fields
}

func (*DockerImage) Descriptor deprecated 

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

Deprecated: Use DockerImage.ProtoReflect.Descriptor instead.

func (*DockerImage) GetId 

func (x *DockerImage) GetId() string

func (*DockerImage) GetTag 

func (x *DockerImage) GetTag() string

func (*DockerImage) GetUri 

func (x *DockerImage) GetUri() string

func (*DockerImage) ProtoMessage 

func (*DockerImage) ProtoMessage()

func (*DockerImage) ProtoReflect 

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

func (*DockerImage) Reset 

func (x *DockerImage) Reset()

func (*DockerImage) String 

func (x *DockerImage) String() string

type EngineClient 

type EngineClient interface {
	HeartBeats(ctx context.Context, in *HeartBeatsRequest, opts ...grpc.CallOption) (*HeartBeatsResponse, error)
	GetNewJob(ctx context.Context, in *JobGetRequest, opts ...grpc.CallOption) (*JobGetResponse, error)
	PopulateJobResult(ctx context.Context, in *JobPopulateRequest, opts ...grpc.CallOption) (*JobPopulateResponse, error)
}

EngineClient is the client API for Engine 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 NewEngineClient 

func NewEngineClient(cc grpc.ClientConnInterface) EngineClient

type EngineServer 

type EngineServer interface {
	HeartBeats(context.Context, *HeartBeatsRequest) (*HeartBeatsResponse, error)
	GetNewJob(context.Context, *JobGetRequest) (*JobGetResponse, error)
	PopulateJobResult(context.Context, *JobPopulateRequest) (*JobPopulateResponse, error)
	// contains filtered or unexported methods
}

EngineServer is the server API for Engine service. All implementations must embed UnimplementedEngineServer for forward compatibility

type EnumFileFetchMethod 

type EnumFileFetchMethod int32
const (
	EnumFileFetchMethod_EFFM_UNSPECIFIED EnumFileFetchMethod = 0
	EnumFileFetchMethod_EFFM_HTTP        EnumFileFetchMethod = 1
	EnumFileFetchMethod_EFFM_GRPC_STREAM EnumFileFetchMethod = 2
)

func (EnumFileFetchMethod) Descriptor 

func (EnumFileFetchMethod) Descriptor() protoreflect.EnumDescriptor

func (EnumFileFetchMethod) Enum 

func (x EnumFileFetchMethod) Enum() *EnumFileFetchMethod

func (EnumFileFetchMethod) EnumDescriptor deprecated 

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

Deprecated: Use EnumFileFetchMethod.Descriptor instead.

func (EnumFileFetchMethod) Number 

func (x EnumFileFetchMethod) Number() protoreflect.EnumNumber

func (EnumFileFetchMethod) String 

func (x EnumFileFetchMethod) String() string

func (EnumFileFetchMethod) Type 

func (EnumFileFetchMethod) Type() protoreflect.EnumType

type EnumFileOperation 

type EnumFileOperation int32
const (
	EnumFileOperation_EFO_UNSPECIFIED EnumFileOperation = 0
	EnumFileOperation_EFO_UNTAR       EnumFileOperation = 1
)

func (EnumFileOperation) Descriptor 

func (EnumFileOperation) Descriptor() protoreflect.EnumDescriptor

func (EnumFileOperation) Enum 

func (x EnumFileOperation) Enum() *EnumFileOperation

func (EnumFileOperation) EnumDescriptor deprecated 

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

Deprecated: Use EnumFileOperation.Descriptor instead.

func (EnumFileOperation) Number 

func (x EnumFileOperation) Number() protoreflect.EnumNumber

func (EnumFileOperation) String 

func (x EnumFileOperation) String() string

func (EnumFileOperation) Type 

func (EnumFileOperation) Type() protoreflect.EnumType

type EnumFileType 

type EnumFileType int32
const (
	EnumFileType_EFT_UNSPECIFIED EnumFileType = 0
	EnumFileType_EFT_TAR         EnumFileType = 1
)

func (EnumFileType) Descriptor 

func (EnumFileType) Descriptor() protoreflect.EnumDescriptor

func (EnumFileType) Enum 

func (x EnumFileType) Enum() *EnumFileType

func (EnumFileType) EnumDescriptor deprecated 

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

Deprecated: Use EnumFileType.Descriptor instead.

func (EnumFileType) Number 

func (x EnumFileType) Number() protoreflect.EnumNumber

func (EnumFileType) String 

func (x EnumFileType) String() string

func (EnumFileType) Type 

func (EnumFileType) Type() protoreflect.EnumType

type File 

type File struct {
	Name       string            `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Type       EnumFileType      `protobuf:"varint,2,opt,name=type,proto3,enum=protobuf.EnumFileType" json:"type,omitempty"`
	Preprocess EnumFileOperation `protobuf:"varint,3,opt,name=preprocess,proto3,enum=protobuf.EnumFileOperation" json:"preprocess,omitempty"`
	// Types that are assignable to Content:
	//	*File_Data
	//	*File_Remote
	Content isFile_Content `protobuf_oneof:"content"`
	// contains filtered or unexported fields
}

func (*File) Descriptor deprecated 

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

Deprecated: Use File.ProtoReflect.Descriptor instead.

func (*File) GetContent 

func (m *File) GetContent() isFile_Content

func (*File) GetData 

func (x *File) GetData() []byte

func (*File) GetName 

func (x *File) GetName() string

func (*File) GetPreprocess 

func (x *File) GetPreprocess() EnumFileOperation

func (*File) GetRemote 

func (x *File) GetRemote() *FileUri

func (*File) GetType 

func (x *File) GetType() EnumFileType

func (*File) ProtoMessage 

func (*File) ProtoMessage()

func (*File) ProtoReflect 

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

func (*File) Reset 

func (x *File) Reset()

func (*File) String 

func (x *File) String() string

type FileUri 

type FileUri struct {
	Uri         string              `protobuf:"bytes,1,opt,name=uri,proto3" json:"uri,omitempty"`
	FetchMethod EnumFileFetchMethod `` /* 129-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*FileUri) Descriptor deprecated 

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

Deprecated: Use FileUri.ProtoReflect.Descriptor instead.

func (*FileUri) GetFetchMethod 

func (x *FileUri) GetFetchMethod() EnumFileFetchMethod

func (*FileUri) GetUri 

func (x *FileUri) GetUri() string

func (*FileUri) ProtoMessage 

func (*FileUri) ProtoMessage()

func (*FileUri) ProtoReflect 

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

func (*FileUri) Reset 

func (x *FileUri) Reset()

func (*FileUri) String 

func (x *FileUri) String() string

type File_Data 

type File_Data struct {
	Data []byte `protobuf:"bytes,4,opt,name=data,proto3,oneof"`
}

type File_Remote 

type File_Remote struct {
	Remote *FileUri `protobuf:"bytes,5,opt,name=remote,proto3,oneof"`
}

type HeartBeatsRequest 

type HeartBeatsRequest struct {
	DeviceId string `protobuf:"bytes,1,opt,name=device_id,json=deviceId,proto3" json:"device_id,omitempty"`
	Os       string `protobuf:"bytes,2,opt,name=os,proto3" json:"os,omitempty"`
	CpuInfo  string `protobuf:"bytes,3,opt,name=cpu_info,json=cpuInfo,proto3" json:"cpu_info,omitempty"`
	MemInfo  string `protobuf:"bytes,4,opt,name=mem_info,json=memInfo,proto3" json:"mem_info,omitempty"`
	Ip       string `protobuf:"bytes,5,opt,name=ip,proto3" json:"ip,omitempty"`
	// contains filtered or unexported fields
}

func (*HeartBeatsRequest) Descriptor deprecated 

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

Deprecated: Use HeartBeatsRequest.ProtoReflect.Descriptor instead.

func (*HeartBeatsRequest) GetCpuInfo 

func (x *HeartBeatsRequest) GetCpuInfo() string

func (*HeartBeatsRequest) GetDeviceId 

func (x *HeartBeatsRequest) GetDeviceId() string

func (*HeartBeatsRequest) GetIp 

func (x *HeartBeatsRequest) GetIp() string

func (*HeartBeatsRequest) GetMemInfo 

func (x *HeartBeatsRequest) GetMemInfo() string

func (*HeartBeatsRequest) GetOs 

func (x *HeartBeatsRequest) GetOs() string

func (*HeartBeatsRequest) ProtoMessage 

func (*HeartBeatsRequest) ProtoMessage()

func (*HeartBeatsRequest) ProtoReflect 

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

func (*HeartBeatsRequest) Reset 

func (x *HeartBeatsRequest) Reset()

func (*HeartBeatsRequest) String 

func (x *HeartBeatsRequest) String() string

type HeartBeatsResponse 

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

func (*HeartBeatsResponse) Descriptor deprecated 

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

Deprecated: Use HeartBeatsResponse.ProtoReflect.Descriptor instead.

func (*HeartBeatsResponse) ProtoMessage 

func (*HeartBeatsResponse) ProtoMessage()

func (*HeartBeatsResponse) ProtoReflect 

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

func (*HeartBeatsResponse) Reset 

func (x *HeartBeatsResponse) Reset()

func (*HeartBeatsResponse) String 

func (x *HeartBeatsResponse) String() string

type JobGetRequest 

type JobGetRequest struct {
	UserId     string `protobuf:"bytes,1,opt,name=user_id,json=userId,proto3" json:"user_id,omitempty"`
	DeviceId   string `protobuf:"bytes,2,opt,name=device_id,json=deviceId,proto3" json:"device_id,omitempty"`
	DeviceInfo string `protobuf:"bytes,3,opt,name=device_info,json=deviceInfo,proto3" json:"device_info,omitempty"`
	// contains filtered or unexported fields
}

func (*JobGetRequest) Descriptor deprecated 

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

Deprecated: Use JobGetRequest.ProtoReflect.Descriptor instead.

func (*JobGetRequest) GetDeviceId 

func (x *JobGetRequest) GetDeviceId() string

func (*JobGetRequest) GetDeviceInfo 

func (x *JobGetRequest) GetDeviceInfo() string

func (*JobGetRequest) GetUserId 

func (x *JobGetRequest) GetUserId() string

func (*JobGetRequest) ProtoMessage 

func (*JobGetRequest) ProtoMessage()

func (*JobGetRequest) ProtoReflect 

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

func (*JobGetRequest) Reset 

func (x *JobGetRequest) Reset()

func (*JobGetRequest) String 

func (x *JobGetRequest) String() string

type JobGetResponse 

type JobGetResponse struct {
	JobId      string       `protobuf:"bytes,1,opt,name=job_id,json=jobId,proto3" json:"job_id,omitempty"`
	Image      *DockerImage `protobuf:"bytes,2,opt,name=image,proto3" json:"image,omitempty"`
	Cmds       []string     `protobuf:"bytes,3,rep,name=cmds,proto3" json:"cmds,omitempty"`
	VolumePath string       `protobuf:"bytes,4,opt,name=volume_path,json=volumePath,proto3" json:"volume_path,omitempty"`
	Files      []*File      `protobuf:"bytes,5,rep,name=files,proto3" json:"files,omitempty"`
	Outputs    []string     `protobuf:"bytes,6,rep,name=outputs,proto3" json:"outputs,omitempty"`
	// contains filtered or unexported fields
}

func (*JobGetResponse) Descriptor deprecated 

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

Deprecated: Use JobGetResponse.ProtoReflect.Descriptor instead.

func (*JobGetResponse) GetCmds 

func (x *JobGetResponse) GetCmds() []string

func (*JobGetResponse) GetFiles 

func (x *JobGetResponse) GetFiles() []*File

func (*JobGetResponse) GetImage 

func (x *JobGetResponse) GetImage() *DockerImage

func (*JobGetResponse) GetJobId 

func (x *JobGetResponse) GetJobId() string

func (*JobGetResponse) GetOutputs 

func (x *JobGetResponse) GetOutputs() []string

func (*JobGetResponse) GetVolumePath 

func (x *JobGetResponse) GetVolumePath() string

func (*JobGetResponse) ProtoMessage 

func (*JobGetResponse) ProtoMessage()

func (*JobGetResponse) ProtoReflect 

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

func (*JobGetResponse) Reset 

func (x *JobGetResponse) Reset()

func (*JobGetResponse) String 

func (x *JobGetResponse) String() string

type JobPopulateRequest 

type JobPopulateRequest struct {
	JobId    string `protobuf:"bytes,1,opt,name=job_id,json=jobId,proto3" json:"job_id,omitempty"`
	UserId   string `protobuf:"bytes,2,opt,name=user_id,json=userId,proto3" json:"user_id,omitempty"`
	DeviceId string `protobuf:"bytes,3,opt,name=device_id,json=deviceId,proto3" json:"device_id,omitempty"`
	Result   []byte `protobuf:"bytes,4,opt,name=result,proto3" json:"result,omitempty"`
	// contains filtered or unexported fields
}

func (*JobPopulateRequest) Descriptor deprecated 

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

Deprecated: Use JobPopulateRequest.ProtoReflect.Descriptor instead.

func (*JobPopulateRequest) GetDeviceId 

func (x *JobPopulateRequest) GetDeviceId() string

func (*JobPopulateRequest) GetJobId 

func (x *JobPopulateRequest) GetJobId() string

func (*JobPopulateRequest) GetResult 

func (x *JobPopulateRequest) GetResult() []byte

func (*JobPopulateRequest) GetUserId 

func (x *JobPopulateRequest) GetUserId() string

func (*JobPopulateRequest) ProtoMessage 

func (*JobPopulateRequest) ProtoMessage()

func (*JobPopulateRequest) ProtoReflect 

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

func (*JobPopulateRequest) Reset 

func (x *JobPopulateRequest) Reset()

func (*JobPopulateRequest) String 

func (x *JobPopulateRequest) String() string

type JobPopulateResponse 

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

func (*JobPopulateResponse) Descriptor deprecated 

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

Deprecated: Use JobPopulateResponse.ProtoReflect.Descriptor instead.

func (*JobPopulateResponse) ProtoMessage 

func (*JobPopulateResponse) ProtoMessage()

func (*JobPopulateResponse) ProtoReflect 

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

func (*JobPopulateResponse) Reset 

func (x *JobPopulateResponse) Reset()

func (*JobPopulateResponse) String 

func (x *JobPopulateResponse) String() string

type UnimplementedEngineServer 

type UnimplementedEngineServer struct {
}

UnimplementedEngineServer must be embedded to have forward compatible implementations.

func (UnimplementedEngineServer) GetNewJob 

func (UnimplementedEngineServer) GetNewJob(context.Context, *JobGetRequest) (*JobGetResponse, error)

func (UnimplementedEngineServer) HeartBeats 

func (UnimplementedEngineServer) HeartBeats(context.Context, *HeartBeatsRequest) (*HeartBeatsResponse, error)

func (UnimplementedEngineServer) PopulateJobResult 

func (UnimplementedEngineServer) PopulateJobResult(context.Context, *JobPopulateRequest) (*JobPopulateResponse, error)

type UnsafeEngineServer 

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

UnsafeEngineServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to EngineServer 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.