Versions in this module Expand all Collapse all v1 v1.0.0 Jun 24, 2021 Changes in this version + func RegisterLoadBalancerServer(s *grpc.Server, srv LoadBalancerServer) + type ClientStats struct + CallsFinishedWithDrop []*ClientStatsPerToken + NumCallsFinished int64 + NumCallsFinishedKnownReceived int64 + NumCallsFinishedWithClientFailedToSend int64 + NumCallsStarted int64 + Timestamp *timestamp.Timestamp + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*ClientStats) Descriptor() ([]byte, []int) + func (*ClientStats) ProtoMessage() + func (m *ClientStats) GetCallsFinishedWithDrop() []*ClientStatsPerToken + func (m *ClientStats) GetNumCallsFinished() int64 + func (m *ClientStats) GetNumCallsFinishedKnownReceived() int64 + func (m *ClientStats) GetNumCallsFinishedWithClientFailedToSend() int64 + func (m *ClientStats) GetNumCallsStarted() int64 + func (m *ClientStats) GetTimestamp() *timestamp.Timestamp + func (m *ClientStats) Reset() + func (m *ClientStats) String() string + func (m *ClientStats) XXX_DiscardUnknown() + func (m *ClientStats) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *ClientStats) XXX_Merge(src proto.Message) + func (m *ClientStats) XXX_Size() int + func (m *ClientStats) XXX_Unmarshal(b []byte) error + type ClientStatsPerToken struct + LoadBalanceToken string + NumCalls int64 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*ClientStatsPerToken) Descriptor() ([]byte, []int) + func (*ClientStatsPerToken) ProtoMessage() + func (m *ClientStatsPerToken) GetLoadBalanceToken() string + func (m *ClientStatsPerToken) GetNumCalls() int64 + func (m *ClientStatsPerToken) Reset() + func (m *ClientStatsPerToken) String() string + func (m *ClientStatsPerToken) XXX_DiscardUnknown() + func (m *ClientStatsPerToken) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *ClientStatsPerToken) XXX_Merge(src proto.Message) + func (m *ClientStatsPerToken) XXX_Size() int + func (m *ClientStatsPerToken) XXX_Unmarshal(b []byte) error + type FallbackResponse struct + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*FallbackResponse) Descriptor() ([]byte, []int) + func (*FallbackResponse) ProtoMessage() + func (m *FallbackResponse) Reset() + func (m *FallbackResponse) String() string + func (m *FallbackResponse) XXX_DiscardUnknown() + func (m *FallbackResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *FallbackResponse) XXX_Merge(src proto.Message) + func (m *FallbackResponse) XXX_Size() int + func (m *FallbackResponse) XXX_Unmarshal(b []byte) error + type InitialLoadBalanceRequest struct + Name string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*InitialLoadBalanceRequest) Descriptor() ([]byte, []int) + func (*InitialLoadBalanceRequest) ProtoMessage() + func (m *InitialLoadBalanceRequest) GetName() string + func (m *InitialLoadBalanceRequest) Reset() + func (m *InitialLoadBalanceRequest) String() string + func (m *InitialLoadBalanceRequest) XXX_DiscardUnknown() + func (m *InitialLoadBalanceRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *InitialLoadBalanceRequest) XXX_Merge(src proto.Message) + func (m *InitialLoadBalanceRequest) XXX_Size() int + func (m *InitialLoadBalanceRequest) XXX_Unmarshal(b []byte) error + type InitialLoadBalanceResponse struct + ClientStatsReportInterval *duration.Duration + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*InitialLoadBalanceResponse) Descriptor() ([]byte, []int) + func (*InitialLoadBalanceResponse) ProtoMessage() + func (m *InitialLoadBalanceResponse) GetClientStatsReportInterval() *duration.Duration + func (m *InitialLoadBalanceResponse) Reset() + func (m *InitialLoadBalanceResponse) String() string + func (m *InitialLoadBalanceResponse) XXX_DiscardUnknown() + func (m *InitialLoadBalanceResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *InitialLoadBalanceResponse) XXX_Merge(src proto.Message) + func (m *InitialLoadBalanceResponse) XXX_Size() int + func (m *InitialLoadBalanceResponse) XXX_Unmarshal(b []byte) error + type LoadBalanceRequest struct + LoadBalanceRequestType isLoadBalanceRequest_LoadBalanceRequestType + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*LoadBalanceRequest) Descriptor() ([]byte, []int) + func (*LoadBalanceRequest) ProtoMessage() + func (*LoadBalanceRequest) XXX_OneofWrappers() []interface{} + func (m *LoadBalanceRequest) GetClientStats() *ClientStats + func (m *LoadBalanceRequest) GetInitialRequest() *InitialLoadBalanceRequest + func (m *LoadBalanceRequest) GetLoadBalanceRequestType() isLoadBalanceRequest_LoadBalanceRequestType + func (m *LoadBalanceRequest) Reset() + func (m *LoadBalanceRequest) String() string + func (m *LoadBalanceRequest) XXX_DiscardUnknown() + func (m *LoadBalanceRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *LoadBalanceRequest) XXX_Merge(src proto.Message) + func (m *LoadBalanceRequest) XXX_Size() int + func (m *LoadBalanceRequest) XXX_Unmarshal(b []byte) error + type LoadBalanceRequest_ClientStats struct + ClientStats *ClientStats + type LoadBalanceRequest_InitialRequest struct + InitialRequest *InitialLoadBalanceRequest + type LoadBalanceResponse struct + LoadBalanceResponseType isLoadBalanceResponse_LoadBalanceResponseType + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*LoadBalanceResponse) Descriptor() ([]byte, []int) + func (*LoadBalanceResponse) ProtoMessage() + func (*LoadBalanceResponse) XXX_OneofWrappers() []interface{} + func (m *LoadBalanceResponse) GetFallbackResponse() *FallbackResponse + func (m *LoadBalanceResponse) GetInitialResponse() *InitialLoadBalanceResponse + func (m *LoadBalanceResponse) GetLoadBalanceResponseType() isLoadBalanceResponse_LoadBalanceResponseType + func (m *LoadBalanceResponse) GetServerList() *ServerList + func (m *LoadBalanceResponse) Reset() + func (m *LoadBalanceResponse) String() string + func (m *LoadBalanceResponse) XXX_DiscardUnknown() + func (m *LoadBalanceResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *LoadBalanceResponse) XXX_Merge(src proto.Message) + func (m *LoadBalanceResponse) XXX_Size() int + func (m *LoadBalanceResponse) XXX_Unmarshal(b []byte) error + type LoadBalanceResponse_FallbackResponse struct + FallbackResponse *FallbackResponse + type LoadBalanceResponse_InitialResponse struct + InitialResponse *InitialLoadBalanceResponse + type LoadBalanceResponse_ServerList struct + ServerList *ServerList + type LoadBalancerClient interface + BalanceLoad func(ctx context.Context, opts ...grpc.CallOption) (LoadBalancer_BalanceLoadClient, error) + func NewLoadBalancerClient(cc grpc.ClientConnInterface) LoadBalancerClient + type LoadBalancerServer interface + BalanceLoad func(LoadBalancer_BalanceLoadServer) error + type LoadBalancer_BalanceLoadClient interface + Recv func() (*LoadBalanceResponse, error) + Send func(*LoadBalanceRequest) error + type LoadBalancer_BalanceLoadServer interface + Recv func() (*LoadBalanceRequest, error) + Send func(*LoadBalanceResponse) error + type Server struct + Drop bool + IpAddress []byte + LoadBalanceToken string + Port int32 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*Server) Descriptor() ([]byte, []int) + func (*Server) ProtoMessage() + func (m *Server) GetDrop() bool + func (m *Server) GetIpAddress() []byte + func (m *Server) GetLoadBalanceToken() string + func (m *Server) GetPort() int32 + func (m *Server) Reset() + func (m *Server) String() string + func (m *Server) XXX_DiscardUnknown() + func (m *Server) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *Server) XXX_Merge(src proto.Message) + func (m *Server) XXX_Size() int + func (m *Server) XXX_Unmarshal(b []byte) error + type ServerList struct + Servers []*Server + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*ServerList) Descriptor() ([]byte, []int) + func (*ServerList) ProtoMessage() + func (m *ServerList) GetServers() []*Server + func (m *ServerList) Reset() + func (m *ServerList) String() string + func (m *ServerList) XXX_DiscardUnknown() + func (m *ServerList) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *ServerList) XXX_Merge(src proto.Message) + func (m *ServerList) XXX_Size() int + func (m *ServerList) XXX_Unmarshal(b []byte) error + type UnimplementedLoadBalancerServer struct + func (*UnimplementedLoadBalancerServer) BalanceLoad(srv LoadBalancer_BalanceLoadServer) error
Go to main page