Documentation ¶
Index ¶
- Constants
- Variables
- func RegisterLoadBalancerServer(s grpc.ServiceRegistrar, srv LoadBalancerServer)
- func RegisterLoadReporterServer(s grpc.ServiceRegistrar, srv LoadReporterServer)
- type LoadBalancerClient
- type LoadBalancerServer
- type LoadBalancer_BalanceLoadClient
- type LoadBalancer_BalanceLoadServer
- type LoadReporterClient
- type LoadReporterServer
- type LoadReporter_ReportLoadClient
- type LoadReporter_ReportLoadServer
- type UnimplementedLoadBalancerServer
- type UnimplementedLoadReporterServer
- type UnsafeLoadBalancerServer
- type UnsafeLoadReporterServer
Constants ¶
const (
LoadBalancer_BalanceLoad_FullMethodName = "/grpc.lb.v1.LoadBalancer/BalanceLoad"
)
const (
LoadReporter_ReportLoad_FullMethodName = "/grpc.lb.v1.LoadReporter/ReportLoad"
)
Variables ¶
var LoadBalancer_ServiceDesc = grpc.ServiceDesc{ ServiceName: "grpc.lb.v1.LoadBalancer", HandlerType: (*LoadBalancerServer)(nil), Methods: []grpc.MethodDesc{}, Streams: []grpc.StreamDesc{ { StreamName: "BalanceLoad", Handler: _LoadBalancer_BalanceLoad_Handler, ServerStreams: true, ClientStreams: true, }, }, Metadata: "grpc/lb/v1/load_balancer.proto", }
LoadBalancer_ServiceDesc is the grpc.ServiceDesc for LoadBalancer service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
var LoadReporter_ServiceDesc = grpc.ServiceDesc{ ServiceName: "grpc.lb.v1.LoadReporter", HandlerType: (*LoadReporterServer)(nil), Methods: []grpc.MethodDesc{}, Streams: []grpc.StreamDesc{ { StreamName: "ReportLoad", Handler: _LoadReporter_ReportLoad_Handler, ServerStreams: true, ClientStreams: true, }, }, Metadata: "grpc/lb/v1/load_reporter.proto", }
LoadReporter_ServiceDesc is the grpc.ServiceDesc for LoadReporter service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
Functions ¶
func RegisterLoadBalancerServer ¶
func RegisterLoadBalancerServer(s grpc.ServiceRegistrar, srv LoadBalancerServer)
func RegisterLoadReporterServer ¶
func RegisterLoadReporterServer(s grpc.ServiceRegistrar, srv LoadReporterServer)
Types ¶
type LoadBalancerClient ¶
type LoadBalancerClient interface { // Bidirectional rpc to get a list of servers. BalanceLoad(ctx context.Context, opts ...grpc.CallOption) (LoadBalancer_BalanceLoadClient, error) }
LoadBalancerClient is the client API for LoadBalancer 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 NewLoadBalancerClient ¶
func NewLoadBalancerClient(cc grpc.ClientConnInterface) LoadBalancerClient
type LoadBalancerServer ¶
type LoadBalancerServer interface { // Bidirectional rpc to get a list of servers. BalanceLoad(LoadBalancer_BalanceLoadServer) error }
LoadBalancerServer is the server API for LoadBalancer service. All implementations should embed UnimplementedLoadBalancerServer for forward compatibility
type LoadBalancer_BalanceLoadClient ¶
type LoadBalancer_BalanceLoadClient interface { Send(*v1.LoadBalanceRequest) error Recv() (*v1.LoadBalanceResponse, error) grpc.ClientStream }
type LoadBalancer_BalanceLoadServer ¶
type LoadBalancer_BalanceLoadServer interface { Send(*v1.LoadBalanceResponse) error Recv() (*v1.LoadBalanceRequest, error) grpc.ServerStream }
type LoadReporterClient ¶
type LoadReporterClient interface { // Report load from server to lb. ReportLoad(ctx context.Context, opts ...grpc.CallOption) (LoadReporter_ReportLoadClient, error) }
LoadReporterClient is the client API for LoadReporter 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 NewLoadReporterClient ¶
func NewLoadReporterClient(cc grpc.ClientConnInterface) LoadReporterClient
type LoadReporterServer ¶
type LoadReporterServer interface { // Report load from server to lb. ReportLoad(LoadReporter_ReportLoadServer) error }
LoadReporterServer is the server API for LoadReporter service. All implementations should embed UnimplementedLoadReporterServer for forward compatibility
type LoadReporter_ReportLoadClient ¶
type LoadReporter_ReportLoadClient interface { Send(*v1.LoadReportRequest) error Recv() (*v1.LoadReportResponse, error) grpc.ClientStream }
type LoadReporter_ReportLoadServer ¶
type LoadReporter_ReportLoadServer interface { Send(*v1.LoadReportResponse) error Recv() (*v1.LoadReportRequest, error) grpc.ServerStream }
type UnimplementedLoadBalancerServer ¶
type UnimplementedLoadBalancerServer struct { }
UnimplementedLoadBalancerServer should be embedded to have forward compatible implementations.
func (UnimplementedLoadBalancerServer) BalanceLoad ¶
func (UnimplementedLoadBalancerServer) BalanceLoad(LoadBalancer_BalanceLoadServer) error
type UnimplementedLoadReporterServer ¶
type UnimplementedLoadReporterServer struct { }
UnimplementedLoadReporterServer should be embedded to have forward compatible implementations.
func (UnimplementedLoadReporterServer) ReportLoad ¶
func (UnimplementedLoadReporterServer) ReportLoad(LoadReporter_ReportLoadServer) error
type UnsafeLoadBalancerServer ¶
type UnsafeLoadBalancerServer interface {
// contains filtered or unexported methods
}
UnsafeLoadBalancerServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to LoadBalancerServer will result in compilation errors.
type UnsafeLoadReporterServer ¶
type UnsafeLoadReporterServer interface {
// contains filtered or unexported methods
}
UnsafeLoadReporterServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to LoadReporterServer will result in compilation errors.