lbv1grpc

Documentation

Index

• Constants
• Variables
• func RegisterLoadBalancerServer(s grpc.ServiceRegistrar, srv LoadBalancerServer)
• func RegisterLoadReporterServer(s grpc.ServiceRegistrar, srv LoadReporterServer)
• type LoadBalancerClient
  • func NewLoadBalancerClient(cc grpc.ClientConnInterface) LoadBalancerClient
• type LoadBalancerServer
• type LoadBalancer_BalanceLoadClient
• type LoadBalancer_BalanceLoadServer
• type LoadReporterClient
  • func NewLoadReporterClient(cc grpc.ClientConnInterface) LoadReporterClient
• type LoadReporterServer
• type LoadReporter_ReportLoadClient
• type LoadReporter_ReportLoadServer
• type UnimplementedLoadBalancerServer
  • func (UnimplementedLoadBalancerServer) BalanceLoad(LoadBalancer_BalanceLoadServer) error
• type UnimplementedLoadReporterServer
  • func (UnimplementedLoadReporterServer) ReportLoad(LoadReporter_ReportLoadServer) error
• 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.