proto

package
v0.0.0-...-3233e8b Latest Latest
Warning

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

 Go to latest Published: Dec 8, 2023 License: BSD-3-Clause Imports: 10 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	RpcService_Call_FullMethodName = "/tensorflow.rpc.RpcService/Call"
	RpcService_List_FullMethodName = "/tensorflow.rpc.RpcService/List"
)

Variables

View Source 
var File_tensorflow_distribute_experimental_rpc_proto_tf_rpc_service_proto protoreflect.FileDescriptor
View Source 
var RpcService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "tensorflow.rpc.RpcService",
	HandlerType: (*RpcServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Call",
			Handler:    _RpcService_Call_Handler,
		},
		{
			MethodName: "List",
			Handler:    _RpcService_List_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "tensorflow/distribute/experimental/rpc/proto/tf_rpc_service.proto",
}

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

Functions

func RegisterRpcServiceServer 

func RegisterRpcServiceServer(s grpc.ServiceRegistrar, srv RpcServiceServer)

Types

type CallRequest 

type CallRequest struct {
	Method       string                   `protobuf:"bytes,1,opt,name=method,proto3" json:"method,omitempty"`
	InputTensors []*framework.TensorProto `protobuf:"bytes,2,rep,name=input_tensors,json=inputTensors,proto3" json:"input_tensors,omitempty"`
	// contains filtered or unexported fields
}

func (*CallRequest) Descriptor deprecated 

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

Deprecated: Use CallRequest.ProtoReflect.Descriptor instead.

func (*CallRequest) GetInputTensors 

func (x *CallRequest) GetInputTensors() []*framework.TensorProto

func (*CallRequest) GetMethod 

func (x *CallRequest) GetMethod() string

func (*CallRequest) ProtoMessage 

func (*CallRequest) ProtoMessage()

func (*CallRequest) ProtoReflect 

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

func (*CallRequest) Reset 

func (x *CallRequest) Reset()

func (*CallRequest) String 

func (x *CallRequest) String() string

type CallResponse 

type CallResponse struct {
	OutputTensors []*framework.TensorProto `protobuf:"bytes,1,rep,name=output_tensors,json=outputTensors,proto3" json:"output_tensors,omitempty"`
	// contains filtered or unexported fields
}

func (*CallResponse) Descriptor deprecated 

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

Deprecated: Use CallResponse.ProtoReflect.Descriptor instead.

func (*CallResponse) GetOutputTensors 

func (x *CallResponse) GetOutputTensors() []*framework.TensorProto

func (*CallResponse) ProtoMessage 

func (*CallResponse) ProtoMessage()

func (*CallResponse) ProtoReflect 

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

func (*CallResponse) Reset 

func (x *CallResponse) Reset()

func (*CallResponse) String 

func (x *CallResponse) String() string

type ListRequest 

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

func (*ListRequest) Descriptor deprecated 

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

Deprecated: Use ListRequest.ProtoReflect.Descriptor instead.

func (*ListRequest) ProtoMessage 

func (*ListRequest) ProtoMessage()

func (*ListRequest) ProtoReflect 

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

func (*ListRequest) Reset 

func (x *ListRequest) Reset()

func (*ListRequest) String 

func (x *ListRequest) String() string

type ListResponse 

type ListResponse struct {
	RegisteredMethods []*RegisteredMethod `protobuf:"bytes,1,rep,name=registered_methods,json=registeredMethods,proto3" json:"registered_methods,omitempty"`
	// contains filtered or unexported fields
}

func (*ListResponse) Descriptor deprecated 

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

Deprecated: Use ListResponse.ProtoReflect.Descriptor instead.

func (*ListResponse) GetRegisteredMethods 

func (x *ListResponse) GetRegisteredMethods() []*RegisteredMethod

func (*ListResponse) ProtoMessage 

func (*ListResponse) ProtoMessage()

func (*ListResponse) ProtoReflect 

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

func (*ListResponse) Reset 

func (x *ListResponse) Reset()

func (*ListResponse) String 

func (x *ListResponse) String() string

type RegisteredMethod 

type RegisteredMethod struct {
	Method      string                    `protobuf:"bytes,1,opt,name=method,proto3" json:"method,omitempty"`
	InputSpecs  *protobuf.StructuredValue `protobuf:"bytes,2,opt,name=input_specs,json=inputSpecs,proto3" json:"input_specs,omitempty"`
	OutputSpecs *protobuf.StructuredValue `protobuf:"bytes,3,opt,name=output_specs,json=outputSpecs,proto3" json:"output_specs,omitempty"`
	// contains filtered or unexported fields
}

func (*RegisteredMethod) Descriptor deprecated 

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

Deprecated: Use RegisteredMethod.ProtoReflect.Descriptor instead.

func (*RegisteredMethod) GetInputSpecs 

func (x *RegisteredMethod) GetInputSpecs() *protobuf.StructuredValue

func (*RegisteredMethod) GetMethod 

func (x *RegisteredMethod) GetMethod() string

func (*RegisteredMethod) GetOutputSpecs 

func (x *RegisteredMethod) GetOutputSpecs() *protobuf.StructuredValue

func (*RegisteredMethod) ProtoMessage 

func (*RegisteredMethod) ProtoMessage()

func (*RegisteredMethod) ProtoReflect 

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

func (*RegisteredMethod) Reset 

func (x *RegisteredMethod) Reset()

func (*RegisteredMethod) String 

func (x *RegisteredMethod) String() string

type RpcServiceClient 

type RpcServiceClient interface {
	// RPC for invoking a registered function on remote server.
	Call(ctx context.Context, in *CallRequest, opts ...grpc.CallOption) (*CallResponse, error)
	// RPC for listing available methods in a server.
	List(ctx context.Context, in *ListRequest, opts ...grpc.CallOption) (*ListResponse, error)
}

RpcServiceClient is the client API for RpcService 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 NewRpcServiceClient 

func NewRpcServiceClient(cc grpc.ClientConnInterface) RpcServiceClient

type RpcServiceServer 

type RpcServiceServer interface {
	// RPC for invoking a registered function on remote server.
	Call(context.Context, *CallRequest) (*CallResponse, error)
	// RPC for listing available methods in a server.
	List(context.Context, *ListRequest) (*ListResponse, error)
	// contains filtered or unexported methods
}

RpcServiceServer is the server API for RpcService service. All implementations must embed UnimplementedRpcServiceServer for forward compatibility

type UnimplementedRpcServiceServer 

type UnimplementedRpcServiceServer struct {
}

UnimplementedRpcServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedRpcServiceServer) Call 

func (UnimplementedRpcServiceServer) Call(context.Context, *CallRequest) (*CallResponse, error)

func (UnimplementedRpcServiceServer) List 

func (UnimplementedRpcServiceServer) List(context.Context, *ListRequest) (*ListResponse, error)

type UnsafeRpcServiceServer 

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

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