Documentation ¶
Index ¶
- Variables
- func RegisterAuthorityServer(s grpc.ServiceRegistrar, srv AuthorityServer)
- type AuthorityClient
- type AuthorityServer
- type Authority_ServersClient
- type Authority_ServersServer
- type ServerMsg
- type ServersReq
- func (*ServersReq) Descriptor() ([]byte, []int)deprecated
- func (x *ServersReq) GetDatacenterFilter() []string
- func (x *ServersReq) GetNameFilterRe() string
- func (*ServersReq) ProtoMessage()
- func (x *ServersReq) ProtoReflect() protoreflect.Message
- func (x *ServersReq) Reset()
- func (x *ServersReq) String() string
- type UnimplementedAuthorityServer
- type UnsafeAuthorityServer
Constants ¶
This section is empty.
Variables ¶
var Authority_ServiceDesc = grpc.ServiceDesc{ ServiceName: "grpc_testing.authority.Authority", HandlerType: (*AuthorityServer)(nil), Methods: []grpc.MethodDesc{}, Streams: []grpc.StreamDesc{ { StreamName: "Servers", Handler: _Authority_Servers_Handler, ServerStreams: true, }, }, Metadata: "medium/grpc_testing/proto/authority.proto", }
Authority_ServiceDesc is the grpc.ServiceDesc for Authority service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
Functions ¶
func RegisterAuthorityServer ¶
func RegisterAuthorityServer(s grpc.ServiceRegistrar, srv AuthorityServer)
Types ¶
type AuthorityClient ¶
type AuthorityClient interface { // ProcessExporter instructs the Processor to process some data from an exporter and // stream the results back. Servers(ctx context.Context, in *ServersReq, opts ...grpc.CallOption) (Authority_ServersClient, error) }
AuthorityClient is the client API for Authority service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.golang.ir/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.
func NewAuthorityClient ¶
func NewAuthorityClient(cc grpc.ClientConnInterface) AuthorityClient
type AuthorityServer ¶
type AuthorityServer interface { // ProcessExporter instructs the Processor to process some data from an exporter and // stream the results back. Servers(*ServersReq, Authority_ServersServer) error // contains filtered or unexported methods }
AuthorityServer is the server API for Authority service. All implementations must embed UnimplementedAuthorityServer for forward compatibility
type Authority_ServersClient ¶
type Authority_ServersClient interface { Recv() (*ServerMsg, error) grpc.ClientStream }
type Authority_ServersServer ¶
type Authority_ServersServer interface { Send(*ServerMsg) error grpc.ServerStream }
type ServerMsg ¶
type ServerMsg struct { Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` // contains filtered or unexported fields }
func (*ServerMsg) Descriptor
deprecated
func (*ServerMsg) ProtoMessage ¶
func (*ServerMsg) ProtoMessage()
func (*ServerMsg) ProtoReflect ¶
func (x *ServerMsg) ProtoReflect() protoreflect.Message
type ServersReq ¶
type ServersReq struct { NameFilterRe string `protobuf:"bytes,1,opt,name=name_filter_re,json=nameFilterRe,proto3" json:"name_filter_re,omitempty"` DatacenterFilter []string `protobuf:"bytes,2,rep,name=datacenter_filter,json=datacenterFilter,proto3" json:"datacenter_filter,omitempty"` // contains filtered or unexported fields }
func (*ServersReq) Descriptor
deprecated
func (*ServersReq) Descriptor() ([]byte, []int)
Deprecated: Use ServersReq.ProtoReflect.Descriptor instead.
func (*ServersReq) GetDatacenterFilter ¶
func (x *ServersReq) GetDatacenterFilter() []string
func (*ServersReq) GetNameFilterRe ¶
func (x *ServersReq) GetNameFilterRe() string
func (*ServersReq) ProtoMessage ¶
func (*ServersReq) ProtoMessage()
func (*ServersReq) ProtoReflect ¶
func (x *ServersReq) ProtoReflect() protoreflect.Message
func (*ServersReq) Reset ¶
func (x *ServersReq) Reset()
func (*ServersReq) String ¶
func (x *ServersReq) String() string
type UnimplementedAuthorityServer ¶
type UnimplementedAuthorityServer struct { }
UnimplementedAuthorityServer must be embedded to have forward compatible implementations.
func (UnimplementedAuthorityServer) Servers ¶
func (UnimplementedAuthorityServer) Servers(*ServersReq, Authority_ServersServer) error
type UnsafeAuthorityServer ¶
type UnsafeAuthorityServer interface {
// contains filtered or unexported methods
}
UnsafeAuthorityServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to AuthorityServer will result in compilation errors.