Versions in this module Expand all Collapse all v0 v0.26.0 Apr 9, 2022 Changes in this version + var ErrIntOverflowRpc = fmt.Errorf("proto: integer overflow") + var ErrInvalidLengthRpc = fmt.Errorf("proto: negative length found during unmarshaling") + var ErrUnexpectedEndOfGroupRpc = fmt.Errorf("proto: unexpected end of group") + var TargetHealth_name = map[int32]string + var TargetHealth_value = map[string]int32 + var TargetsRequest_State_name = map[int32]string + var TargetsRequest_State_value = map[string]int32 + func RegisterTargetsServer(s *grpc.Server, srv TargetsServer) + type ActiveTarget struct + DiscoveredLabels labelpb.ZLabelSet + GlobalUrl string + Health TargetHealth + Labels labelpb.ZLabelSet + LastError string + LastScrape time.Time + LastScrapeDuration float64 + ScrapePool string + ScrapeUrl string + func (*ActiveTarget) Descriptor() ([]byte, []int) + func (*ActiveTarget) ProtoMessage() + func (m *ActiveTarget) Marshal() (dAtA []byte, err error) + func (m *ActiveTarget) MarshalTo(dAtA []byte) (int, error) + func (m *ActiveTarget) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *ActiveTarget) Reset() + func (m *ActiveTarget) Size() (n int) + func (m *ActiveTarget) String() string + func (m *ActiveTarget) Unmarshal(dAtA []byte) error + func (m *ActiveTarget) XXX_DiscardUnknown() + func (m *ActiveTarget) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *ActiveTarget) XXX_Merge(src proto.Message) + func (m *ActiveTarget) XXX_Size() int + func (m *ActiveTarget) XXX_Unmarshal(b []byte) error + func (t *ActiveTarget) SetDiscoveredLabels(ls labels.Labels) + func (t *ActiveTarget) SetLabels(ls labels.Labels) + func (t1 *ActiveTarget) Compare(t2 *ActiveTarget) int + func (t1 *ActiveTarget) CompareState(t2 *ActiveTarget) int + type DroppedTarget struct + DiscoveredLabels labelpb.ZLabelSet + func (*DroppedTarget) Descriptor() ([]byte, []int) + func (*DroppedTarget) ProtoMessage() + func (m *DroppedTarget) Marshal() (dAtA []byte, err error) + func (m *DroppedTarget) MarshalTo(dAtA []byte) (int, error) + func (m *DroppedTarget) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *DroppedTarget) Reset() + func (m *DroppedTarget) Size() (n int) + func (m *DroppedTarget) String() string + func (m *DroppedTarget) Unmarshal(dAtA []byte) error + func (m *DroppedTarget) XXX_DiscardUnknown() + func (m *DroppedTarget) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *DroppedTarget) XXX_Merge(src proto.Message) + func (m *DroppedTarget) XXX_Size() int + func (m *DroppedTarget) XXX_Unmarshal(b []byte) error + func (t *DroppedTarget) SetDiscoveredLabels(ls labels.Labels) + func (t1 *DroppedTarget) Compare(t2 *DroppedTarget) int + type TargetDiscovery struct + ActiveTargets []*ActiveTarget + DroppedTargets []*DroppedTarget + func (*TargetDiscovery) Descriptor() ([]byte, []int) + func (*TargetDiscovery) ProtoMessage() + func (m *TargetDiscovery) Marshal() (dAtA []byte, err error) + func (m *TargetDiscovery) MarshalTo(dAtA []byte) (int, error) + func (m *TargetDiscovery) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *TargetDiscovery) Reset() + func (m *TargetDiscovery) Size() (n int) + func (m *TargetDiscovery) String() string + func (m *TargetDiscovery) Unmarshal(dAtA []byte) error + func (m *TargetDiscovery) XXX_DiscardUnknown() + func (m *TargetDiscovery) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *TargetDiscovery) XXX_Merge(src proto.Message) + func (m *TargetDiscovery) XXX_Size() int + func (m *TargetDiscovery) XXX_Unmarshal(b []byte) error + type TargetHealth int32 + const TargetHealth_DOWN + const TargetHealth_UP + func (TargetHealth) EnumDescriptor() ([]byte, []int) + func (x *TargetHealth) MarshalJSON() ([]byte, error) + func (x *TargetHealth) UnmarshalJSON(entry []byte) error + func (x TargetHealth) Compare(y TargetHealth) int + func (x TargetHealth) String() string + type TargetsClient interface + Targets func(ctx context.Context, in *TargetsRequest, opts ...grpc.CallOption) (Targets_TargetsClient, error) + func NewTargetsClient(cc *grpc.ClientConn) TargetsClient + type TargetsRequest struct + PartialResponseStrategy storepb.PartialResponseStrategy + State TargetsRequest_State + func (*TargetsRequest) Descriptor() ([]byte, []int) + func (*TargetsRequest) ProtoMessage() + func (m *TargetsRequest) Marshal() (dAtA []byte, err error) + func (m *TargetsRequest) MarshalTo(dAtA []byte) (int, error) + func (m *TargetsRequest) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *TargetsRequest) Reset() + func (m *TargetsRequest) Size() (n int) + func (m *TargetsRequest) String() string + func (m *TargetsRequest) Unmarshal(dAtA []byte) error + func (m *TargetsRequest) XXX_DiscardUnknown() + func (m *TargetsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *TargetsRequest) XXX_Merge(src proto.Message) + func (m *TargetsRequest) XXX_Size() int + func (m *TargetsRequest) XXX_Unmarshal(b []byte) error + type TargetsRequest_State int32 + const TargetsRequest_ACTIVE + const TargetsRequest_ANY + const TargetsRequest_DROPPED + func (TargetsRequest_State) EnumDescriptor() ([]byte, []int) + func (x TargetsRequest_State) String() string + type TargetsResponse struct + Result isTargetsResponse_Result + func NewTargetsResponse(targets *TargetDiscovery) *TargetsResponse + func NewWarningTargetsResponse(warning error) *TargetsResponse + func (*TargetsResponse) Descriptor() ([]byte, []int) + func (*TargetsResponse) ProtoMessage() + func (*TargetsResponse) XXX_OneofWrappers() []interface{} + func (m *TargetsResponse) GetResult() isTargetsResponse_Result + func (m *TargetsResponse) GetTargets() *TargetDiscovery + func (m *TargetsResponse) GetWarning() string + func (m *TargetsResponse) Marshal() (dAtA []byte, err error) + func (m *TargetsResponse) MarshalTo(dAtA []byte) (int, error) + func (m *TargetsResponse) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *TargetsResponse) Reset() + func (m *TargetsResponse) Size() (n int) + func (m *TargetsResponse) String() string + func (m *TargetsResponse) Unmarshal(dAtA []byte) error + func (m *TargetsResponse) XXX_DiscardUnknown() + func (m *TargetsResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *TargetsResponse) XXX_Merge(src proto.Message) + func (m *TargetsResponse) XXX_Size() int + func (m *TargetsResponse) XXX_Unmarshal(b []byte) error + type TargetsResponse_Targets struct + Targets *TargetDiscovery + func (m *TargetsResponse_Targets) MarshalTo(dAtA []byte) (int, error) + func (m *TargetsResponse_Targets) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *TargetsResponse_Targets) Size() (n int) + type TargetsResponse_Warning struct + Warning string + func (m *TargetsResponse_Warning) MarshalTo(dAtA []byte) (int, error) + func (m *TargetsResponse_Warning) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *TargetsResponse_Warning) Size() (n int) + type TargetsServer interface + Targets func(*TargetsRequest, Targets_TargetsServer) error + type Targets_TargetsClient interface + Recv func() (*TargetsResponse, error) + type Targets_TargetsServer interface + Send func(*TargetsResponse) error + type UnimplementedTargetsServer struct + func (*UnimplementedTargetsServer) Targets(req *TargetsRequest, srv Targets_TargetsServer) error