Versions in this module Expand all Collapse all v0 v0.6.1 Oct 15, 2018 v0.6.0 Sep 25, 2018 v0.5.0 Aug 14, 2018 Changes in this version + var ErrIntOverflowLrs = fmt.Errorf("proto: integer overflow") + var ErrInvalidLengthLrs = fmt.Errorf("proto: negative length found during unmarshaling") + func RegisterLoadReportingServiceServer(s *grpc.Server, srv LoadReportingServiceServer) + type LoadReportingServiceClient interface + StreamLoadStats func(ctx context.Context, opts ...grpc.CallOption) (LoadReportingService_StreamLoadStatsClient, error) + func NewLoadReportingServiceClient(cc *grpc.ClientConn) LoadReportingServiceClient + type LoadReportingServiceServer interface + StreamLoadStats func(LoadReportingService_StreamLoadStatsServer) error + type LoadReportingService_StreamLoadStatsClient interface + Recv func() (*LoadStatsResponse, error) + Send func(*LoadStatsRequest) error + type LoadReportingService_StreamLoadStatsServer interface + Recv func() (*LoadStatsRequest, error) + Send func(*LoadStatsResponse) error + type LoadStatsRequest struct + ClusterStats []*endpoint.ClusterStats + Node *core.Node + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*LoadStatsRequest) Descriptor() ([]byte, []int) + func (*LoadStatsRequest) ProtoMessage() + func (dst *LoadStatsRequest) XXX_Merge(src proto.Message) + func (m *LoadStatsRequest) GetClusterStats() []*endpoint.ClusterStats + func (m *LoadStatsRequest) GetNode() *core.Node + func (m *LoadStatsRequest) Marshal() (dAtA []byte, err error) + func (m *LoadStatsRequest) MarshalTo(dAtA []byte) (int, error) + func (m *LoadStatsRequest) Reset() + func (m *LoadStatsRequest) Size() (n int) + func (m *LoadStatsRequest) String() string + func (m *LoadStatsRequest) Unmarshal(dAtA []byte) error + func (m *LoadStatsRequest) Validate() error + func (m *LoadStatsRequest) XXX_DiscardUnknown() + func (m *LoadStatsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *LoadStatsRequest) XXX_Size() int + func (m *LoadStatsRequest) XXX_Unmarshal(b []byte) error + type LoadStatsRequestValidationError struct + Cause error + Field string + Key bool + Reason string + func (e LoadStatsRequestValidationError) Error() string + type LoadStatsResponse struct + Clusters []string + LoadReportingInterval *types.Duration + ReportEndpointGranularity bool + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*LoadStatsResponse) Descriptor() ([]byte, []int) + func (*LoadStatsResponse) ProtoMessage() + func (dst *LoadStatsResponse) XXX_Merge(src proto.Message) + func (m *LoadStatsResponse) GetClusters() []string + func (m *LoadStatsResponse) GetLoadReportingInterval() *types.Duration + func (m *LoadStatsResponse) GetReportEndpointGranularity() bool + func (m *LoadStatsResponse) Marshal() (dAtA []byte, err error) + func (m *LoadStatsResponse) MarshalTo(dAtA []byte) (int, error) + func (m *LoadStatsResponse) Reset() + func (m *LoadStatsResponse) Size() (n int) + func (m *LoadStatsResponse) String() string + func (m *LoadStatsResponse) Unmarshal(dAtA []byte) error + func (m *LoadStatsResponse) Validate() error + func (m *LoadStatsResponse) XXX_DiscardUnknown() + func (m *LoadStatsResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *LoadStatsResponse) XXX_Size() int + func (m *LoadStatsResponse) XXX_Unmarshal(b []byte) error + type LoadStatsResponseValidationError struct + Cause error + Field string + Key bool + Reason string + func (e LoadStatsResponseValidationError) Error() string