proto

package
v0.0.0-...-74d777d Latest Latest
Warning

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

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

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	ExecuteStream_Type_name = map[int32]string{
		0: "Unknown",
		1: "Connect",
		2: "Execute",
		3: "Result",
	}
	ExecuteStream_Type_value = map[string]int32{
		"Unknown": 0,
		"Connect": 1,
		"Execute": 2,
		"Result":  3,
	}
)

Enum value maps for ExecuteStream_Type.

View Source 
var File_proto_gotlin_proto protoreflect.FileDescriptor
View Source 
var ServerService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "proto.ServerService",
	HandlerType: (*ServerServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "RegisterExecutor",
			Handler:    _ServerService_RegisterExecutor_Handler,
		},
		{
			MethodName: "UnregisterExecutor",
			Handler:    _ServerService_UnregisterExecutor_Handler,
		},
		{
			MethodName: "RequestScheduler",
			Handler:    _ServerService_RequestScheduler_Handler,
		},
		{
			MethodName: "RunProgram",
			Handler:    _ServerService_RunProgram_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "Execute",
			Handler:       _ServerService_Execute_Handler,
			ServerStreams: true,
			ClientStreams: true,
		},
		{
			StreamName:    "WaitResult",
			Handler:       _ServerService_WaitResult_Handler,
			ServerStreams: true,
		},
	},
	Metadata: "proto/gotlin.proto",
}

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

Functions

func RegisterServerServiceServer 

func RegisterServerServiceServer(s grpc.ServiceRegistrar, srv ServerServiceServer)

Types

type ExecuteStream 

type ExecuteStream struct {
	Id      string             `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Type    ExecuteStream_Type `protobuf:"varint,2,opt,name=type,proto3,enum=proto.ExecuteStream_Type" json:"type,omitempty"`
	Spent   int64              `protobuf:"varint,3,opt,name=spent,proto3" json:"spent,omitempty"`
	Timeout int64              `protobuf:"varint,4,opt,name=timeout,proto3" json:"timeout,omitempty"`
	Error   string             `protobuf:"bytes,5,opt,name=error,proto3" json:"error,omitempty"`
	Op      *InstructionPb     `protobuf:"bytes,6,opt,name=op,proto3" json:"op,omitempty"`
	Args    []*InstructionPb   `protobuf:"bytes,7,rep,name=args,proto3" json:"args,omitempty"`
	Result  *InstructionPb     `protobuf:"bytes,8,opt,name=result,proto3" json:"result,omitempty"`
	// contains filtered or unexported fields
}

func (*ExecuteStream) Descriptor deprecated 

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

Deprecated: Use ExecuteStream.ProtoReflect.Descriptor instead.

func (*ExecuteStream) GetArgs 

func (x *ExecuteStream) GetArgs() []*InstructionPb

func (*ExecuteStream) GetError 

func (x *ExecuteStream) GetError() string

func (*ExecuteStream) GetId 

func (x *ExecuteStream) GetId() string

func (*ExecuteStream) GetOp 

func (x *ExecuteStream) GetOp() *InstructionPb

func (*ExecuteStream) GetResult 

func (x *ExecuteStream) GetResult() *InstructionPb

func (*ExecuteStream) GetSpent 

func (x *ExecuteStream) GetSpent() int64

func (*ExecuteStream) GetTimeout 

func (x *ExecuteStream) GetTimeout() int64

func (*ExecuteStream) GetType 

func (x *ExecuteStream) GetType() ExecuteStream_Type

func (*ExecuteStream) ProtoMessage 

func (*ExecuteStream) ProtoMessage()

func (*ExecuteStream) ProtoReflect 

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

func (*ExecuteStream) Reset 

func (x *ExecuteStream) Reset()

func (*ExecuteStream) String 

func (x *ExecuteStream) String() string

type ExecuteStream_Type 

type ExecuteStream_Type int32
const (
	ExecuteStream_Unknown ExecuteStream_Type = 0
	ExecuteStream_Connect ExecuteStream_Type = 1
	ExecuteStream_Execute ExecuteStream_Type = 2
	ExecuteStream_Result  ExecuteStream_Type = 3
)

func (ExecuteStream_Type) Descriptor 

func (ExecuteStream_Type) Descriptor() protoreflect.EnumDescriptor

func (ExecuteStream_Type) Enum 

func (x ExecuteStream_Type) Enum() *ExecuteStream_Type

func (ExecuteStream_Type) EnumDescriptor deprecated 

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

Deprecated: Use ExecuteStream_Type.Descriptor instead.

func (ExecuteStream_Type) Number 

func (x ExecuteStream_Type) Number() protoreflect.EnumNumber

func (ExecuteStream_Type) String 

func (x ExecuteStream_Type) String() string

func (ExecuteStream_Type) Type 

func (ExecuteStream_Type) Type() protoreflect.EnumType

type InstructionPb 

type InstructionPb struct {
	Id      string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Id2     string `protobuf:"bytes,2,opt,name=id2,proto3" json:"id2,omitempty"`
	Opcode  string `protobuf:"bytes,3,opt,name=opcode,proto3" json:"opcode,omitempty"`
	Operand []byte `protobuf:"bytes,4,opt,name=operand,proto3" json:"operand,omitempty"`
	Result  []byte `protobuf:"bytes,5,opt,name=result,proto3" json:"result,omitempty"`
	// contains filtered or unexported fields
}

func (*InstructionPb) Descriptor deprecated 

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

Deprecated: Use InstructionPb.ProtoReflect.Descriptor instead.

func (*InstructionPb) GetId 

func (x *InstructionPb) GetId() string

func (*InstructionPb) GetId2 

func (x *InstructionPb) GetId2() string

func (*InstructionPb) GetOpcode 

func (x *InstructionPb) GetOpcode() string

func (*InstructionPb) GetOperand 

func (x *InstructionPb) GetOperand() []byte

func (*InstructionPb) GetResult 

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

func (*InstructionPb) ProtoMessage 

func (*InstructionPb) ProtoMessage()

func (*InstructionPb) ProtoReflect 

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

func (*InstructionPb) Reset 

func (x *InstructionPb) Reset()

func (*InstructionPb) String 

func (x *InstructionPb) String() string

type ProgramPb 

type ProgramPb struct {
	Id        string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Code      []byte `protobuf:"bytes,2,opt,name=code,proto3" json:"code,omitempty"`
	Processor []byte `protobuf:"bytes,3,opt,name=processor,proto3" json:"processor,omitempty"`
	// contains filtered or unexported fields
}

func (*ProgramPb) Descriptor deprecated 

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

Deprecated: Use ProgramPb.ProtoReflect.Descriptor instead.

func (*ProgramPb) GetCode 

func (x *ProgramPb) GetCode() []byte

func (*ProgramPb) GetId 

func (x *ProgramPb) GetId() string

func (*ProgramPb) GetProcessor 

func (x *ProgramPb) GetProcessor() []byte

func (*ProgramPb) ProtoMessage 

func (*ProgramPb) ProtoMessage()

func (*ProgramPb) ProtoReflect 

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

func (*ProgramPb) Reset 

func (x *ProgramPb) Reset()

func (*ProgramPb) String 

func (x *ProgramPb) String() string

type RegisterExecutorRequest 

type RegisterExecutorRequest struct {
	Id     string                           `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Labels []*RegisterExecutorRequest_Label `protobuf:"bytes,2,rep,name=labels,proto3" json:"labels,omitempty"`
	Host   string                           `protobuf:"bytes,3,opt,name=host,proto3" json:"host,omitempty"`
	// contains filtered or unexported fields
}

func (*RegisterExecutorRequest) Descriptor deprecated 

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

Deprecated: Use RegisterExecutorRequest.ProtoReflect.Descriptor instead.

func (*RegisterExecutorRequest) GetHost 

func (x *RegisterExecutorRequest) GetHost() string

func (*RegisterExecutorRequest) GetId 

func (x *RegisterExecutorRequest) GetId() string

func (*RegisterExecutorRequest) GetLabels 

func (x *RegisterExecutorRequest) GetLabels() []*RegisterExecutorRequest_Label

func (*RegisterExecutorRequest) ProtoMessage 

func (*RegisterExecutorRequest) ProtoMessage()

func (*RegisterExecutorRequest) ProtoReflect 

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

func (*RegisterExecutorRequest) Reset 

func (x *RegisterExecutorRequest) Reset()

func (*RegisterExecutorRequest) String 

func (x *RegisterExecutorRequest) String() string

type RegisterExecutorRequest_Label 

type RegisterExecutorRequest_Label struct {
	Key   string `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	Value string `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
	// contains filtered or unexported fields
}

func (*RegisterExecutorRequest_Label) Descriptor deprecated 

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

Deprecated: Use RegisterExecutorRequest_Label.ProtoReflect.Descriptor instead.

func (*RegisterExecutorRequest_Label) GetKey 

func (x *RegisterExecutorRequest_Label) GetKey() string

func (*RegisterExecutorRequest_Label) GetValue 

func (x *RegisterExecutorRequest_Label) GetValue() string

func (*RegisterExecutorRequest_Label) ProtoMessage 

func (*RegisterExecutorRequest_Label) ProtoMessage()

func (*RegisterExecutorRequest_Label) ProtoReflect 

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

func (*RegisterExecutorRequest_Label) Reset 

func (x *RegisterExecutorRequest_Label) Reset()

func (*RegisterExecutorRequest_Label) String 

func (x *RegisterExecutorRequest_Label) String() string

type RegisterExecutorResponse 

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

func (*RegisterExecutorResponse) Descriptor deprecated 

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

Deprecated: Use RegisterExecutorResponse.ProtoReflect.Descriptor instead.

func (*RegisterExecutorResponse) ProtoMessage 

func (*RegisterExecutorResponse) ProtoMessage()

func (*RegisterExecutorResponse) ProtoReflect 

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

func (*RegisterExecutorResponse) Reset 

func (x *RegisterExecutorResponse) Reset()

func (*RegisterExecutorResponse) String 

func (x *RegisterExecutorResponse) String() string

type RequestSchedulerRequest 

type RequestSchedulerRequest struct {
	Dummy string `protobuf:"bytes,1,opt,name=dummy,proto3" json:"dummy,omitempty"`
	// contains filtered or unexported fields
}

func (*RequestSchedulerRequest) Descriptor deprecated 

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

Deprecated: Use RequestSchedulerRequest.ProtoReflect.Descriptor instead.

func (*RequestSchedulerRequest) GetDummy 

func (x *RequestSchedulerRequest) GetDummy() string

func (*RequestSchedulerRequest) ProtoMessage 

func (*RequestSchedulerRequest) ProtoMessage()

func (*RequestSchedulerRequest) ProtoReflect 

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

func (*RequestSchedulerRequest) Reset 

func (x *RequestSchedulerRequest) Reset()

func (*RequestSchedulerRequest) String 

func (x *RequestSchedulerRequest) String() string

type RequestSchedulerResponse 

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

func (*RequestSchedulerResponse) Descriptor deprecated 

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

Deprecated: Use RequestSchedulerResponse.ProtoReflect.Descriptor instead.

func (*RequestSchedulerResponse) GetId 

func (x *RequestSchedulerResponse) GetId() string

func (*RequestSchedulerResponse) ProtoMessage 

func (*RequestSchedulerResponse) ProtoMessage()

func (*RequestSchedulerResponse) ProtoReflect 

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

func (*RequestSchedulerResponse) Reset 

func (x *RequestSchedulerResponse) Reset()

func (*RequestSchedulerResponse) String 

func (x *RequestSchedulerResponse) String() string

type RunProgramRequest 

type RunProgramRequest struct {
	SchedulerId  string           `protobuf:"bytes,1,opt,name=scheduler_id,json=schedulerId,proto3" json:"scheduler_id,omitempty"`
	Program      *ProgramPb       `protobuf:"bytes,2,opt,name=program,proto3" json:"program,omitempty"`
	Instructions []*InstructionPb `protobuf:"bytes,3,rep,name=instructions,proto3" json:"instructions,omitempty"`
	// contains filtered or unexported fields
}

func (*RunProgramRequest) Descriptor deprecated 

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

Deprecated: Use RunProgramRequest.ProtoReflect.Descriptor instead.

func (*RunProgramRequest) GetInstructions 

func (x *RunProgramRequest) GetInstructions() []*InstructionPb

func (*RunProgramRequest) GetProgram 

func (x *RunProgramRequest) GetProgram() *ProgramPb

func (*RunProgramRequest) GetSchedulerId 

func (x *RunProgramRequest) GetSchedulerId() string

func (*RunProgramRequest) ProtoMessage 

func (*RunProgramRequest) ProtoMessage()

func (*RunProgramRequest) ProtoReflect 

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

func (*RunProgramRequest) Reset 

func (x *RunProgramRequest) Reset()

func (*RunProgramRequest) String 

func (x *RunProgramRequest) String() string

type RunProgramResponse 

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

func (*RunProgramResponse) Descriptor deprecated 

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

Deprecated: Use RunProgramResponse.ProtoReflect.Descriptor instead.

func (*RunProgramResponse) ProtoMessage 

func (*RunProgramResponse) ProtoMessage()

func (*RunProgramResponse) ProtoReflect 

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

func (*RunProgramResponse) Reset 

func (x *RunProgramResponse) Reset()

func (*RunProgramResponse) String 

func (x *RunProgramResponse) String() string

type ServerServiceClient 

type ServerServiceClient interface {
	RegisterExecutor(ctx context.Context, in *RegisterExecutorRequest, opts ...grpc.CallOption) (*RegisterExecutorResponse, error)
	UnregisterExecutor(ctx context.Context, in *UnregisterExecutorRequest, opts ...grpc.CallOption) (*UnregisterExecutorResponse, error)
	Execute(ctx context.Context, opts ...grpc.CallOption) (ServerService_ExecuteClient, error)
	RequestScheduler(ctx context.Context, in *RequestSchedulerRequest, opts ...grpc.CallOption) (*RequestSchedulerResponse, error)
	RunProgram(ctx context.Context, in *RunProgramRequest, opts ...grpc.CallOption) (*RunProgramResponse, error)
	WaitResult(ctx context.Context, in *WaitResultRequest, opts ...grpc.CallOption) (ServerService_WaitResultClient, error)
}

ServerServiceClient is the client API for ServerService 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 NewServerServiceClient 

func NewServerServiceClient(cc grpc.ClientConnInterface) ServerServiceClient

type ServerServiceServer 

type ServerServiceServer interface {
	RegisterExecutor(context.Context, *RegisterExecutorRequest) (*RegisterExecutorResponse, error)
	UnregisterExecutor(context.Context, *UnregisterExecutorRequest) (*UnregisterExecutorResponse, error)
	Execute(ServerService_ExecuteServer) error
	RequestScheduler(context.Context, *RequestSchedulerRequest) (*RequestSchedulerResponse, error)
	RunProgram(context.Context, *RunProgramRequest) (*RunProgramResponse, error)
	WaitResult(*WaitResultRequest, ServerService_WaitResultServer) error
	// contains filtered or unexported methods
}

ServerServiceServer is the server API for ServerService service. All implementations must embed UnimplementedServerServiceServer for forward compatibility

type ServerService_ExecuteClient 

type ServerService_ExecuteClient interface {
	Send(*ExecuteStream) error
	Recv() (*ExecuteStream, error)
	grpc.ClientStream
}

type ServerService_ExecuteServer 

type ServerService_ExecuteServer interface {
	Send(*ExecuteStream) error
	Recv() (*ExecuteStream, error)
	grpc.ServerStream
}

type ServerService_WaitResultClient 

type ServerService_WaitResultClient interface {
	Recv() (*WaitResultResponse, error)
	grpc.ClientStream
}

type ServerService_WaitResultServer 

type ServerService_WaitResultServer interface {
	Send(*WaitResultResponse) error
	grpc.ServerStream
}

type UnimplementedServerServiceServer 

type UnimplementedServerServiceServer struct {
}

UnimplementedServerServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedServerServiceServer) Execute 

func (UnimplementedServerServiceServer) Execute(ServerService_ExecuteServer) error

func (UnimplementedServerServiceServer) RegisterExecutor 

func (UnimplementedServerServiceServer) RegisterExecutor(context.Context, *RegisterExecutorRequest) (*RegisterExecutorResponse, error)

func (UnimplementedServerServiceServer) RequestScheduler 

func (UnimplementedServerServiceServer) RequestScheduler(context.Context, *RequestSchedulerRequest) (*RequestSchedulerResponse, error)

func (UnimplementedServerServiceServer) RunProgram 

func (UnimplementedServerServiceServer) RunProgram(context.Context, *RunProgramRequest) (*RunProgramResponse, error)

func (UnimplementedServerServiceServer) UnregisterExecutor 

func (UnimplementedServerServiceServer) UnregisterExecutor(context.Context, *UnregisterExecutorRequest) (*UnregisterExecutorResponse, error)

func (UnimplementedServerServiceServer) WaitResult 

func (UnimplementedServerServiceServer) WaitResult(*WaitResultRequest, ServerService_WaitResultServer) error

type UnregisterExecutorRequest 

type UnregisterExecutorRequest struct {
	Id    string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Error string `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty"`
	// contains filtered or unexported fields
}

func (*UnregisterExecutorRequest) Descriptor deprecated 

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

Deprecated: Use UnregisterExecutorRequest.ProtoReflect.Descriptor instead.

func (*UnregisterExecutorRequest) GetError 

func (x *UnregisterExecutorRequest) GetError() string

func (*UnregisterExecutorRequest) GetId 

func (x *UnregisterExecutorRequest) GetId() string

func (*UnregisterExecutorRequest) ProtoMessage 

func (*UnregisterExecutorRequest) ProtoMessage()

func (*UnregisterExecutorRequest) ProtoReflect 

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

func (*UnregisterExecutorRequest) Reset 

func (x *UnregisterExecutorRequest) Reset()

func (*UnregisterExecutorRequest) String 

func (x *UnregisterExecutorRequest) String() string

type UnregisterExecutorResponse 

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

func (*UnregisterExecutorResponse) Descriptor deprecated 

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

Deprecated: Use UnregisterExecutorResponse.ProtoReflect.Descriptor instead.

func (*UnregisterExecutorResponse) ProtoMessage 

func (*UnregisterExecutorResponse) ProtoMessage()

func (*UnregisterExecutorResponse) ProtoReflect 

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

func (*UnregisterExecutorResponse) Reset 

func (x *UnregisterExecutorResponse) Reset()

func (*UnregisterExecutorResponse) String 

func (x *UnregisterExecutorResponse) String() string

type UnsafeServerServiceServer 

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

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

type WaitResultRequest 

type WaitResultRequest struct {
	Ids []string `protobuf:"bytes,1,rep,name=ids,proto3" json:"ids,omitempty"`
	// contains filtered or unexported fields
}

func (*WaitResultRequest) Descriptor deprecated 

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

Deprecated: Use WaitResultRequest.ProtoReflect.Descriptor instead.

func (*WaitResultRequest) GetIds 

func (x *WaitResultRequest) GetIds() []string

func (*WaitResultRequest) ProtoMessage 

func (*WaitResultRequest) ProtoMessage()

func (*WaitResultRequest) ProtoReflect 

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

func (*WaitResultRequest) Reset 

func (x *WaitResultRequest) Reset()

func (*WaitResultRequest) String 

func (x *WaitResultRequest) String() string

type WaitResultResponse 

type WaitResultResponse struct {
	Id     string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Result []byte `protobuf:"bytes,2,opt,name=result,proto3" json:"result,omitempty"`
	Error  string `protobuf:"bytes,3,opt,name=error,proto3" json:"error,omitempty"`
	// contains filtered or unexported fields
}

func (*WaitResultResponse) Descriptor deprecated 

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

Deprecated: Use WaitResultResponse.ProtoReflect.Descriptor instead.

func (*WaitResultResponse) GetError 

func (x *WaitResultResponse) GetError() string

func (*WaitResultResponse) GetId 

func (x *WaitResultResponse) GetId() string

func (*WaitResultResponse) GetResult 

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

func (*WaitResultResponse) ProtoMessage 

func (*WaitResultResponse) ProtoMessage()

func (*WaitResultResponse) ProtoReflect 

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

func (*WaitResultResponse) Reset 

func (x *WaitResultResponse) Reset()

func (*WaitResultResponse) String 

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