mirror of
https://github.com/status-im/consul.git
synced 2025-01-09 13:26:07 +00:00
b9e525d689
Previously, public referred to gRPC services that are both exposed on the dedicated gRPC port and have their definitions in the proto-public directory (so were considered usable by 3rd parties). Whereas private referred to services on the multiplexed server port that are only usable by agents and other servers. Now, we're splitting these definitions, such that external/internal refers to the port and public/private refers to whether they can be used by 3rd parties. This is necessary because the peering replication API needs to be exposed on the dedicated port, but is not (yet) suitable for use by 3rd parties.
381 lines
12 KiB
Go
381 lines
12 KiB
Go
// Code generated by protoc-gen-go. DO NOT EDIT.
|
|
// versions:
|
|
// protoc-gen-go v1.23.0
|
|
// protoc v3.15.8
|
|
// source: agent/grpc-internal/internal/testservice/simple.proto
|
|
|
|
package testservice
|
|
|
|
import (
|
|
context "context"
|
|
proto "github.com/golang/protobuf/proto"
|
|
grpc "google.golang.org/grpc"
|
|
codes "google.golang.org/grpc/codes"
|
|
status "google.golang.org/grpc/status"
|
|
protoreflect "google.golang.org/protobuf/reflect/protoreflect"
|
|
protoimpl "google.golang.org/protobuf/runtime/protoimpl"
|
|
reflect "reflect"
|
|
sync "sync"
|
|
)
|
|
|
|
const (
|
|
// Verify that this generated code is sufficiently up-to-date.
|
|
_ = protoimpl.EnforceVersion(20 - protoimpl.MinVersion)
|
|
// Verify that runtime/protoimpl is sufficiently up-to-date.
|
|
_ = protoimpl.EnforceVersion(protoimpl.MaxVersion - 20)
|
|
)
|
|
|
|
// This is a compile-time assertion that a sufficiently up-to-date version
|
|
// of the legacy proto package is being used.
|
|
const _ = proto.ProtoPackageIsVersion4
|
|
|
|
type Req struct {
|
|
state protoimpl.MessageState
|
|
sizeCache protoimpl.SizeCache
|
|
unknownFields protoimpl.UnknownFields
|
|
|
|
Datacenter string `protobuf:"bytes,1,opt,name=Datacenter,proto3" json:"Datacenter,omitempty"`
|
|
}
|
|
|
|
func (x *Req) Reset() {
|
|
*x = Req{}
|
|
if protoimpl.UnsafeEnabled {
|
|
mi := &file_agent_grpc_private_internal_testservice_simple_proto_msgTypes[0]
|
|
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
|
|
ms.StoreMessageInfo(mi)
|
|
}
|
|
}
|
|
|
|
func (x *Req) String() string {
|
|
return protoimpl.X.MessageStringOf(x)
|
|
}
|
|
|
|
func (*Req) ProtoMessage() {}
|
|
|
|
func (x *Req) ProtoReflect() protoreflect.Message {
|
|
mi := &file_agent_grpc_private_internal_testservice_simple_proto_msgTypes[0]
|
|
if protoimpl.UnsafeEnabled && x != nil {
|
|
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
|
|
if ms.LoadMessageInfo() == nil {
|
|
ms.StoreMessageInfo(mi)
|
|
}
|
|
return ms
|
|
}
|
|
return mi.MessageOf(x)
|
|
}
|
|
|
|
// Deprecated: Use Req.ProtoReflect.Descriptor instead.
|
|
func (*Req) Descriptor() ([]byte, []int) {
|
|
return file_agent_grpc_private_internal_testservice_simple_proto_rawDescGZIP(), []int{0}
|
|
}
|
|
|
|
func (x *Req) GetDatacenter() string {
|
|
if x != nil {
|
|
return x.Datacenter
|
|
}
|
|
return ""
|
|
}
|
|
|
|
type Resp struct {
|
|
state protoimpl.MessageState
|
|
sizeCache protoimpl.SizeCache
|
|
unknownFields protoimpl.UnknownFields
|
|
|
|
ServerName string `protobuf:"bytes,1,opt,name=ServerName,proto3" json:"ServerName,omitempty"`
|
|
Datacenter string `protobuf:"bytes,2,opt,name=Datacenter,proto3" json:"Datacenter,omitempty"`
|
|
}
|
|
|
|
func (x *Resp) Reset() {
|
|
*x = Resp{}
|
|
if protoimpl.UnsafeEnabled {
|
|
mi := &file_agent_grpc_private_internal_testservice_simple_proto_msgTypes[1]
|
|
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
|
|
ms.StoreMessageInfo(mi)
|
|
}
|
|
}
|
|
|
|
func (x *Resp) String() string {
|
|
return protoimpl.X.MessageStringOf(x)
|
|
}
|
|
|
|
func (*Resp) ProtoMessage() {}
|
|
|
|
func (x *Resp) ProtoReflect() protoreflect.Message {
|
|
mi := &file_agent_grpc_private_internal_testservice_simple_proto_msgTypes[1]
|
|
if protoimpl.UnsafeEnabled && x != nil {
|
|
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
|
|
if ms.LoadMessageInfo() == nil {
|
|
ms.StoreMessageInfo(mi)
|
|
}
|
|
return ms
|
|
}
|
|
return mi.MessageOf(x)
|
|
}
|
|
|
|
// Deprecated: Use Resp.ProtoReflect.Descriptor instead.
|
|
func (*Resp) Descriptor() ([]byte, []int) {
|
|
return file_agent_grpc_private_internal_testservice_simple_proto_rawDescGZIP(), []int{1}
|
|
}
|
|
|
|
func (x *Resp) GetServerName() string {
|
|
if x != nil {
|
|
return x.ServerName
|
|
}
|
|
return ""
|
|
}
|
|
|
|
func (x *Resp) GetDatacenter() string {
|
|
if x != nil {
|
|
return x.Datacenter
|
|
}
|
|
return ""
|
|
}
|
|
|
|
var File_agent_grpc_private_internal_testservice_simple_proto protoreflect.FileDescriptor
|
|
|
|
var file_agent_grpc_private_internal_testservice_simple_proto_rawDesc = []byte{
|
|
0x0a, 0x34, 0x61, 0x67, 0x65, 0x6e, 0x74, 0x2f, 0x67, 0x72, 0x70, 0x63, 0x2f, 0x70, 0x72, 0x69,
|
|
0x76, 0x61, 0x74, 0x65, 0x2f, 0x69, 0x6e, 0x74, 0x65, 0x72, 0x6e, 0x61, 0x6c, 0x2f, 0x74, 0x65,
|
|
0x73, 0x74, 0x73, 0x65, 0x72, 0x76, 0x69, 0x63, 0x65, 0x2f, 0x73, 0x69, 0x6d, 0x70, 0x6c, 0x65,
|
|
0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x12, 0x0b, 0x74, 0x65, 0x73, 0x74, 0x73, 0x65, 0x72, 0x76,
|
|
0x69, 0x63, 0x65, 0x22, 0x25, 0x0a, 0x03, 0x52, 0x65, 0x71, 0x12, 0x1e, 0x0a, 0x0a, 0x44, 0x61,
|
|
0x74, 0x61, 0x63, 0x65, 0x6e, 0x74, 0x65, 0x72, 0x18, 0x01, 0x20, 0x01, 0x28, 0x09, 0x52, 0x0a,
|
|
0x44, 0x61, 0x74, 0x61, 0x63, 0x65, 0x6e, 0x74, 0x65, 0x72, 0x22, 0x46, 0x0a, 0x04, 0x52, 0x65,
|
|
0x73, 0x70, 0x12, 0x1e, 0x0a, 0x0a, 0x53, 0x65, 0x72, 0x76, 0x65, 0x72, 0x4e, 0x61, 0x6d, 0x65,
|
|
0x18, 0x01, 0x20, 0x01, 0x28, 0x09, 0x52, 0x0a, 0x53, 0x65, 0x72, 0x76, 0x65, 0x72, 0x4e, 0x61,
|
|
0x6d, 0x65, 0x12, 0x1e, 0x0a, 0x0a, 0x44, 0x61, 0x74, 0x61, 0x63, 0x65, 0x6e, 0x74, 0x65, 0x72,
|
|
0x18, 0x02, 0x20, 0x01, 0x28, 0x09, 0x52, 0x0a, 0x44, 0x61, 0x74, 0x61, 0x63, 0x65, 0x6e, 0x74,
|
|
0x65, 0x72, 0x32, 0x6d, 0x0a, 0x06, 0x53, 0x69, 0x6d, 0x70, 0x6c, 0x65, 0x12, 0x32, 0x0a, 0x09,
|
|
0x53, 0x6f, 0x6d, 0x65, 0x74, 0x68, 0x69, 0x6e, 0x67, 0x12, 0x10, 0x2e, 0x74, 0x65, 0x73, 0x74,
|
|
0x73, 0x65, 0x72, 0x76, 0x69, 0x63, 0x65, 0x2e, 0x52, 0x65, 0x71, 0x1a, 0x11, 0x2e, 0x74, 0x65,
|
|
0x73, 0x74, 0x73, 0x65, 0x72, 0x76, 0x69, 0x63, 0x65, 0x2e, 0x52, 0x65, 0x73, 0x70, 0x22, 0x00,
|
|
0x12, 0x2f, 0x0a, 0x04, 0x46, 0x6c, 0x6f, 0x77, 0x12, 0x10, 0x2e, 0x74, 0x65, 0x73, 0x74, 0x73,
|
|
0x65, 0x72, 0x76, 0x69, 0x63, 0x65, 0x2e, 0x52, 0x65, 0x71, 0x1a, 0x11, 0x2e, 0x74, 0x65, 0x73,
|
|
0x74, 0x73, 0x65, 0x72, 0x76, 0x69, 0x63, 0x65, 0x2e, 0x52, 0x65, 0x73, 0x70, 0x22, 0x00, 0x30,
|
|
0x01, 0x62, 0x06, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x33,
|
|
}
|
|
|
|
var (
|
|
file_agent_grpc_private_internal_testservice_simple_proto_rawDescOnce sync.Once
|
|
file_agent_grpc_private_internal_testservice_simple_proto_rawDescData = file_agent_grpc_private_internal_testservice_simple_proto_rawDesc
|
|
)
|
|
|
|
func file_agent_grpc_private_internal_testservice_simple_proto_rawDescGZIP() []byte {
|
|
file_agent_grpc_private_internal_testservice_simple_proto_rawDescOnce.Do(func() {
|
|
file_agent_grpc_private_internal_testservice_simple_proto_rawDescData = protoimpl.X.CompressGZIP(file_agent_grpc_private_internal_testservice_simple_proto_rawDescData)
|
|
})
|
|
return file_agent_grpc_private_internal_testservice_simple_proto_rawDescData
|
|
}
|
|
|
|
var file_agent_grpc_private_internal_testservice_simple_proto_msgTypes = make([]protoimpl.MessageInfo, 2)
|
|
var file_agent_grpc_private_internal_testservice_simple_proto_goTypes = []interface{}{
|
|
(*Req)(nil), // 0: testservice.Req
|
|
(*Resp)(nil), // 1: testservice.Resp
|
|
}
|
|
var file_agent_grpc_private_internal_testservice_simple_proto_depIdxs = []int32{
|
|
0, // 0: testservice.Simple.Something:input_type -> testservice.Req
|
|
0, // 1: testservice.Simple.Flow:input_type -> testservice.Req
|
|
1, // 2: testservice.Simple.Something:output_type -> testservice.Resp
|
|
1, // 3: testservice.Simple.Flow:output_type -> testservice.Resp
|
|
2, // [2:4] is the sub-list for method output_type
|
|
0, // [0:2] is the sub-list for method input_type
|
|
0, // [0:0] is the sub-list for extension type_name
|
|
0, // [0:0] is the sub-list for extension extendee
|
|
0, // [0:0] is the sub-list for field type_name
|
|
}
|
|
|
|
func init() { file_agent_grpc_private_internal_testservice_simple_proto_init() }
|
|
func file_agent_grpc_private_internal_testservice_simple_proto_init() {
|
|
if File_agent_grpc_private_internal_testservice_simple_proto != nil {
|
|
return
|
|
}
|
|
if !protoimpl.UnsafeEnabled {
|
|
file_agent_grpc_private_internal_testservice_simple_proto_msgTypes[0].Exporter = func(v interface{}, i int) interface{} {
|
|
switch v := v.(*Req); i {
|
|
case 0:
|
|
return &v.state
|
|
case 1:
|
|
return &v.sizeCache
|
|
case 2:
|
|
return &v.unknownFields
|
|
default:
|
|
return nil
|
|
}
|
|
}
|
|
file_agent_grpc_private_internal_testservice_simple_proto_msgTypes[1].Exporter = func(v interface{}, i int) interface{} {
|
|
switch v := v.(*Resp); i {
|
|
case 0:
|
|
return &v.state
|
|
case 1:
|
|
return &v.sizeCache
|
|
case 2:
|
|
return &v.unknownFields
|
|
default:
|
|
return nil
|
|
}
|
|
}
|
|
}
|
|
type x struct{}
|
|
out := protoimpl.TypeBuilder{
|
|
File: protoimpl.DescBuilder{
|
|
GoPackagePath: reflect.TypeOf(x{}).PkgPath(),
|
|
RawDescriptor: file_agent_grpc_private_internal_testservice_simple_proto_rawDesc,
|
|
NumEnums: 0,
|
|
NumMessages: 2,
|
|
NumExtensions: 0,
|
|
NumServices: 1,
|
|
},
|
|
GoTypes: file_agent_grpc_private_internal_testservice_simple_proto_goTypes,
|
|
DependencyIndexes: file_agent_grpc_private_internal_testservice_simple_proto_depIdxs,
|
|
MessageInfos: file_agent_grpc_private_internal_testservice_simple_proto_msgTypes,
|
|
}.Build()
|
|
File_agent_grpc_private_internal_testservice_simple_proto = out.File
|
|
file_agent_grpc_private_internal_testservice_simple_proto_rawDesc = nil
|
|
file_agent_grpc_private_internal_testservice_simple_proto_goTypes = nil
|
|
file_agent_grpc_private_internal_testservice_simple_proto_depIdxs = nil
|
|
}
|
|
|
|
// Reference imports to suppress errors if they are not otherwise used.
|
|
var _ context.Context
|
|
var _ grpc.ClientConnInterface
|
|
|
|
// This is a compile-time assertion to ensure that this generated file
|
|
// is compatible with the grpc package it is being compiled against.
|
|
const _ = grpc.SupportPackageIsVersion6
|
|
|
|
// SimpleClient is the client API for Simple service.
|
|
//
|
|
// For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.
|
|
type SimpleClient interface {
|
|
Something(ctx context.Context, in *Req, opts ...grpc.CallOption) (*Resp, error)
|
|
Flow(ctx context.Context, in *Req, opts ...grpc.CallOption) (Simple_FlowClient, error)
|
|
}
|
|
|
|
type simpleClient struct {
|
|
cc grpc.ClientConnInterface
|
|
}
|
|
|
|
func NewSimpleClient(cc grpc.ClientConnInterface) SimpleClient {
|
|
return &simpleClient{cc}
|
|
}
|
|
|
|
func (c *simpleClient) Something(ctx context.Context, in *Req, opts ...grpc.CallOption) (*Resp, error) {
|
|
out := new(Resp)
|
|
err := c.cc.Invoke(ctx, "/testservice.Simple/Something", in, out, opts...)
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
return out, nil
|
|
}
|
|
|
|
func (c *simpleClient) Flow(ctx context.Context, in *Req, opts ...grpc.CallOption) (Simple_FlowClient, error) {
|
|
stream, err := c.cc.NewStream(ctx, &_Simple_serviceDesc.Streams[0], "/testservice.Simple/Flow", opts...)
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
x := &simpleFlowClient{stream}
|
|
if err := x.ClientStream.SendMsg(in); err != nil {
|
|
return nil, err
|
|
}
|
|
if err := x.ClientStream.CloseSend(); err != nil {
|
|
return nil, err
|
|
}
|
|
return x, nil
|
|
}
|
|
|
|
type Simple_FlowClient interface {
|
|
Recv() (*Resp, error)
|
|
grpc.ClientStream
|
|
}
|
|
|
|
type simpleFlowClient struct {
|
|
grpc.ClientStream
|
|
}
|
|
|
|
func (x *simpleFlowClient) Recv() (*Resp, error) {
|
|
m := new(Resp)
|
|
if err := x.ClientStream.RecvMsg(m); err != nil {
|
|
return nil, err
|
|
}
|
|
return m, nil
|
|
}
|
|
|
|
// SimpleServer is the server API for Simple service.
|
|
type SimpleServer interface {
|
|
Something(context.Context, *Req) (*Resp, error)
|
|
Flow(*Req, Simple_FlowServer) error
|
|
}
|
|
|
|
// UnimplementedSimpleServer can be embedded to have forward compatible implementations.
|
|
type UnimplementedSimpleServer struct {
|
|
}
|
|
|
|
func (*UnimplementedSimpleServer) Something(context.Context, *Req) (*Resp, error) {
|
|
return nil, status.Errorf(codes.Unimplemented, "method Something not implemented")
|
|
}
|
|
func (*UnimplementedSimpleServer) Flow(*Req, Simple_FlowServer) error {
|
|
return status.Errorf(codes.Unimplemented, "method Flow not implemented")
|
|
}
|
|
|
|
func RegisterSimpleServer(s *grpc.Server, srv SimpleServer) {
|
|
s.RegisterService(&_Simple_serviceDesc, srv)
|
|
}
|
|
|
|
func _Simple_Something_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
|
|
in := new(Req)
|
|
if err := dec(in); err != nil {
|
|
return nil, err
|
|
}
|
|
if interceptor == nil {
|
|
return srv.(SimpleServer).Something(ctx, in)
|
|
}
|
|
info := &grpc.UnaryServerInfo{
|
|
Server: srv,
|
|
FullMethod: "/testservice.Simple/Something",
|
|
}
|
|
handler := func(ctx context.Context, req interface{}) (interface{}, error) {
|
|
return srv.(SimpleServer).Something(ctx, req.(*Req))
|
|
}
|
|
return interceptor(ctx, in, info, handler)
|
|
}
|
|
|
|
func _Simple_Flow_Handler(srv interface{}, stream grpc.ServerStream) error {
|
|
m := new(Req)
|
|
if err := stream.RecvMsg(m); err != nil {
|
|
return err
|
|
}
|
|
return srv.(SimpleServer).Flow(m, &simpleFlowServer{stream})
|
|
}
|
|
|
|
type Simple_FlowServer interface {
|
|
Send(*Resp) error
|
|
grpc.ServerStream
|
|
}
|
|
|
|
type simpleFlowServer struct {
|
|
grpc.ServerStream
|
|
}
|
|
|
|
func (x *simpleFlowServer) Send(m *Resp) error {
|
|
return x.ServerStream.SendMsg(m)
|
|
}
|
|
|
|
var _Simple_serviceDesc = grpc.ServiceDesc{
|
|
ServiceName: "testservice.Simple",
|
|
HandlerType: (*SimpleServer)(nil),
|
|
Methods: []grpc.MethodDesc{
|
|
{
|
|
MethodName: "Something",
|
|
Handler: _Simple_Something_Handler,
|
|
},
|
|
},
|
|
Streams: []grpc.StreamDesc{
|
|
{
|
|
StreamName: "Flow",
|
|
Handler: _Simple_Flow_Handler,
|
|
ServerStreams: true,
|
|
},
|
|
},
|
|
Metadata: "agent/grpc-internal/internal/testservice/simple.proto",
|
|
}
|