infopb

package
v0.35.0 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: May 2, 2024 License: Apache-2.0 Imports: 12 Imported by: 3

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	ErrInvalidLengthRpc        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowRpc          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupRpc = fmt.Errorf("proto: unexpected end of group")
)

Functions

func RegisterInfoServer 

func RegisterInfoServer(s *grpc.Server, srv InfoServer)

Types

type ExemplarsInfo 

type ExemplarsInfo struct {
	MinTime int64 `protobuf:"varint,1,opt,name=min_time,json=minTime,proto3" json:"min_time,omitempty"`
	MaxTime int64 `protobuf:"varint,2,opt,name=max_time,json=maxTime,proto3" json:"max_time,omitempty"`
}

ExemplarsInfo holds the metadata related to Exemplars API exposed by the component.

func (*ExemplarsInfo) Descriptor 

func (*ExemplarsInfo) Descriptor() ([]byte, []int)

func (*ExemplarsInfo) Marshal 

func (m *ExemplarsInfo) Marshal() (dAtA []byte, err error)

func (*ExemplarsInfo) MarshalTo 

func (m *ExemplarsInfo) MarshalTo(dAtA []byte) (int, error)

func (*ExemplarsInfo) MarshalToSizedBuffer 

func (m *ExemplarsInfo) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ExemplarsInfo) ProtoMessage 

func (*ExemplarsInfo) ProtoMessage()

func (*ExemplarsInfo) Reset 

func (m *ExemplarsInfo) Reset()

func (*ExemplarsInfo) Size 

func (m *ExemplarsInfo) Size() (n int)

func (*ExemplarsInfo) String 

func (m *ExemplarsInfo) String() string

func (*ExemplarsInfo) Unmarshal 

func (m *ExemplarsInfo) Unmarshal(dAtA []byte) error

func (*ExemplarsInfo) XXX_DiscardUnknown 

func (m *ExemplarsInfo) XXX_DiscardUnknown()

func (*ExemplarsInfo) XXX_Marshal 

func (m *ExemplarsInfo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ExemplarsInfo) XXX_Merge 

func (m *ExemplarsInfo) XXX_Merge(src proto.Message)

func (*ExemplarsInfo) XXX_Size 

func (m *ExemplarsInfo) XXX_Size() int

func (*ExemplarsInfo) XXX_Unmarshal 

func (m *ExemplarsInfo) XXX_Unmarshal(b []byte) error

type InfoClient 

type InfoClient interface {
	// Info returns the metadata (Eg. LabelSets, Min/Max time) about all the APIs the component supports.
	Info(ctx context.Context, in *InfoRequest, opts ...grpc.CallOption) (*InfoResponse, error)
}

InfoClient is the client API for Info service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewInfoClient 

func NewInfoClient(cc *grpc.ClientConn) InfoClient

type InfoRequest 

type InfoRequest struct {
}

func (*InfoRequest) Descriptor 

func (*InfoRequest) Descriptor() ([]byte, []int)

func (*InfoRequest) Marshal 

func (m *InfoRequest) Marshal() (dAtA []byte, err error)

func (*InfoRequest) MarshalTo 

func (m *InfoRequest) MarshalTo(dAtA []byte) (int, error)

func (*InfoRequest) MarshalToSizedBuffer 

func (m *InfoRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*InfoRequest) ProtoMessage 

func (*InfoRequest) ProtoMessage()

func (*InfoRequest) Reset 

func (m *InfoRequest) Reset()

func (*InfoRequest) Size 

func (m *InfoRequest) Size() (n int)

func (*InfoRequest) String 

func (m *InfoRequest) String() string

func (*InfoRequest) Unmarshal 

func (m *InfoRequest) Unmarshal(dAtA []byte) error

func (*InfoRequest) XXX_DiscardUnknown 

func (m *InfoRequest) XXX_DiscardUnknown()

func (*InfoRequest) XXX_Marshal 

func (m *InfoRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*InfoRequest) XXX_Merge 

func (m *InfoRequest) XXX_Merge(src proto.Message)

func (*InfoRequest) XXX_Size 

func (m *InfoRequest) XXX_Size() int

func (*InfoRequest) XXX_Unmarshal 

func (m *InfoRequest) XXX_Unmarshal(b []byte) error

type InfoResponse 

type InfoResponse struct {
	LabelSets     []labelpb.ZLabelSet `protobuf:"bytes,1,rep,name=label_sets,json=labelSets,proto3" json:"label_sets"`
	ComponentType string              `protobuf:"bytes,2,opt,name=ComponentType,proto3" json:"ComponentType,omitempty"`
	// StoreInfo holds the metadata related to Store API if exposed by the component otherwise it will be null.
	Store *StoreInfo `protobuf:"bytes,3,opt,name=store,proto3" json:"store,omitempty"`
	// RulesInfo holds the metadata related to Rules API if exposed by the component otherwise it will be null.
	Rules *RulesInfo `protobuf:"bytes,4,opt,name=rules,proto3" json:"rules,omitempty"`
	// MetricMetadataInfo holds the metadata related to Metadata API if exposed by the component otherwise it will be null.
	MetricMetadata *MetricMetadataInfo `protobuf:"bytes,5,opt,name=metric_metadata,json=metricMetadata,proto3" json:"metric_metadata,omitempty"`
	// TargetsInfo holds the metadata related to Targets API if exposed by the component otherwise it will be null.
	Targets *TargetsInfo `protobuf:"bytes,6,opt,name=targets,proto3" json:"targets,omitempty"`
	// ExemplarsInfo holds the metadata related to Exemplars API if exposed by the component otherwise it will be null.
	Exemplars *ExemplarsInfo `protobuf:"bytes,7,opt,name=exemplars,proto3" json:"exemplars,omitempty"`
	// QueryAPIInfo holds the metadata related to Query API if exposed by the component, otherwise it will be null.
	Query *QueryAPIInfo `protobuf:"bytes,8,opt,name=query,proto3" json:"query,omitempty"`
}

func (*InfoResponse) Descriptor 

func (*InfoResponse) Descriptor() ([]byte, []int)

func (*InfoResponse) Marshal 

func (m *InfoResponse) Marshal() (dAtA []byte, err error)

func (*InfoResponse) MarshalTo 

func (m *InfoResponse) MarshalTo(dAtA []byte) (int, error)

func (*InfoResponse) MarshalToSizedBuffer 

func (m *InfoResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*InfoResponse) ProtoMessage 

func (*InfoResponse) ProtoMessage()

func (*InfoResponse) Reset 

func (m *InfoResponse) Reset()

func (*InfoResponse) Size 

func (m *InfoResponse) Size() (n int)

func (*InfoResponse) String 

func (m *InfoResponse) String() string

func (*InfoResponse) Unmarshal 

func (m *InfoResponse) Unmarshal(dAtA []byte) error

func (*InfoResponse) XXX_DiscardUnknown 

func (m *InfoResponse) XXX_DiscardUnknown()

func (*InfoResponse) XXX_Marshal 

func (m *InfoResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*InfoResponse) XXX_Merge 

func (m *InfoResponse) XXX_Merge(src proto.Message)

func (*InfoResponse) XXX_Size 

func (m *InfoResponse) XXX_Size() int

func (*InfoResponse) XXX_Unmarshal 

func (m *InfoResponse) XXX_Unmarshal(b []byte) error

type InfoServer 

type InfoServer interface {
	// Info returns the metadata (Eg. LabelSets, Min/Max time) about all the APIs the component supports.
	Info(context.Context, *InfoRequest) (*InfoResponse, error)
}

InfoServer is the server API for Info service.

type MetricMetadataInfo 

type MetricMetadataInfo struct {
}

MetricMetadataInfo holds the metadata related to Metadata API exposed by the component.

func (*MetricMetadataInfo) Descriptor 

func (*MetricMetadataInfo) Descriptor() ([]byte, []int)

func (*MetricMetadataInfo) Marshal 

func (m *MetricMetadataInfo) Marshal() (dAtA []byte, err error)

func (*MetricMetadataInfo) MarshalTo 

func (m *MetricMetadataInfo) MarshalTo(dAtA []byte) (int, error)

func (*MetricMetadataInfo) MarshalToSizedBuffer 

func (m *MetricMetadataInfo) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*MetricMetadataInfo) ProtoMessage 

func (*MetricMetadataInfo) ProtoMessage()

func (*MetricMetadataInfo) Reset 

func (m *MetricMetadataInfo) Reset()

func (*MetricMetadataInfo) Size 

func (m *MetricMetadataInfo) Size() (n int)

func (*MetricMetadataInfo) String 

func (m *MetricMetadataInfo) String() string

func (*MetricMetadataInfo) Unmarshal 

func (m *MetricMetadataInfo) Unmarshal(dAtA []byte) error

func (*MetricMetadataInfo) XXX_DiscardUnknown 

func (m *MetricMetadataInfo) XXX_DiscardUnknown()

func (*MetricMetadataInfo) XXX_Marshal 

func (m *MetricMetadataInfo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*MetricMetadataInfo) XXX_Merge 

func (m *MetricMetadataInfo) XXX_Merge(src proto.Message)

func (*MetricMetadataInfo) XXX_Size 

func (m *MetricMetadataInfo) XXX_Size() int

func (*MetricMetadataInfo) XXX_Unmarshal 

func (m *MetricMetadataInfo) XXX_Unmarshal(b []byte) error

type QueryAPIInfo added in v0.26.0 

type QueryAPIInfo struct {
}

QueryInfo holds the metadata related to Query API exposed by the component.

func (*QueryAPIInfo) Descriptor added in v0.26.0 

func (*QueryAPIInfo) Descriptor() ([]byte, []int)

func (*QueryAPIInfo) Marshal added in v0.26.0 

func (m *QueryAPIInfo) Marshal() (dAtA []byte, err error)

func (*QueryAPIInfo) MarshalTo added in v0.26.0 

func (m *QueryAPIInfo) MarshalTo(dAtA []byte) (int, error)

func (*QueryAPIInfo) MarshalToSizedBuffer added in v0.26.0 

func (m *QueryAPIInfo) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*QueryAPIInfo) ProtoMessage added in v0.26.0 

func (*QueryAPIInfo) ProtoMessage()

func (*QueryAPIInfo) Reset added in v0.26.0 

func (m *QueryAPIInfo) Reset()

func (*QueryAPIInfo) Size added in v0.26.0 

func (m *QueryAPIInfo) Size() (n int)

func (*QueryAPIInfo) String added in v0.26.0 

func (m *QueryAPIInfo) String() string

func (*QueryAPIInfo) Unmarshal added in v0.26.0 

func (m *QueryAPIInfo) Unmarshal(dAtA []byte) error

func (*QueryAPIInfo) XXX_DiscardUnknown added in v0.26.0 

func (m *QueryAPIInfo) XXX_DiscardUnknown()

func (*QueryAPIInfo) XXX_Marshal added in v0.26.0 

func (m *QueryAPIInfo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*QueryAPIInfo) XXX_Merge added in v0.26.0 

func (m *QueryAPIInfo) XXX_Merge(src proto.Message)

func (*QueryAPIInfo) XXX_Size added in v0.26.0 

func (m *QueryAPIInfo) XXX_Size() int

func (*QueryAPIInfo) XXX_Unmarshal added in v0.26.0 

func (m *QueryAPIInfo) XXX_Unmarshal(b []byte) error

type RulesInfo 

type RulesInfo struct {
}

RulesInfo holds the metadata related to Rules API exposed by the component.

func (*RulesInfo) Descriptor 

func (*RulesInfo) Descriptor() ([]byte, []int)

func (*RulesInfo) Marshal 

func (m *RulesInfo) Marshal() (dAtA []byte, err error)

func (*RulesInfo) MarshalTo 

func (m *RulesInfo) MarshalTo(dAtA []byte) (int, error)

func (*RulesInfo) MarshalToSizedBuffer 

func (m *RulesInfo) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*RulesInfo) ProtoMessage 

func (*RulesInfo) ProtoMessage()

func (*RulesInfo) Reset 

func (m *RulesInfo) Reset()

func (*RulesInfo) Size 

func (m *RulesInfo) Size() (n int)

func (*RulesInfo) String 

func (m *RulesInfo) String() string

func (*RulesInfo) Unmarshal 

func (m *RulesInfo) Unmarshal(dAtA []byte) error

func (*RulesInfo) XXX_DiscardUnknown 

func (m *RulesInfo) XXX_DiscardUnknown()

func (*RulesInfo) XXX_Marshal 

func (m *RulesInfo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*RulesInfo) XXX_Merge 

func (m *RulesInfo) XXX_Merge(src proto.Message)

func (*RulesInfo) XXX_Size 

func (m *RulesInfo) XXX_Size() int

func (*RulesInfo) XXX_Unmarshal 

func (m *RulesInfo) XXX_Unmarshal(b []byte) error

type StoreInfo 

type StoreInfo struct {
	MinTime          int64 `protobuf:"varint,1,opt,name=min_time,json=minTime,proto3" json:"min_time,omitempty"`
	MaxTime          int64 `protobuf:"varint,2,opt,name=max_time,json=maxTime,proto3" json:"max_time,omitempty"`
	SupportsSharding bool  `protobuf:"varint,3,opt,name=supports_sharding,json=supportsSharding,proto3" json:"supports_sharding,omitempty"`
	// replica_aware means this store supports without_replica_labels of StoreAPI.Series.
	SupportsWithoutReplicaLabels bool `` /* 150-byte string literal not displayed */
	// TSDBInfos holds metadata for all TSDBs exposed by the store.
	TsdbInfos []TSDBInfo `protobuf:"bytes,6,rep,name=tsdb_infos,json=tsdbInfos,proto3" json:"tsdb_infos"`
}

StoreInfo holds the metadata related to Store API exposed by the component.

func (*StoreInfo) Descriptor 

func (*StoreInfo) Descriptor() ([]byte, []int)

func (*StoreInfo) Marshal 

func (m *StoreInfo) Marshal() (dAtA []byte, err error)

func (*StoreInfo) MarshalTo 

func (m *StoreInfo) MarshalTo(dAtA []byte) (int, error)

func (*StoreInfo) MarshalToSizedBuffer 

func (m *StoreInfo) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*StoreInfo) ProtoMessage 

func (*StoreInfo) ProtoMessage()

func (*StoreInfo) Reset 

func (m *StoreInfo) Reset()

func (*StoreInfo) Size 

func (m *StoreInfo) Size() (n int)

func (*StoreInfo) String 

func (m *StoreInfo) String() string

func (*StoreInfo) Unmarshal 

func (m *StoreInfo) Unmarshal(dAtA []byte) error

func (*StoreInfo) XXX_DiscardUnknown 

func (m *StoreInfo) XXX_DiscardUnknown()

func (*StoreInfo) XXX_Marshal 

func (m *StoreInfo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*StoreInfo) XXX_Merge 

func (m *StoreInfo) XXX_Merge(src proto.Message)

func (*StoreInfo) XXX_Size 

func (m *StoreInfo) XXX_Size() int

func (*StoreInfo) XXX_Unmarshal 

func (m *StoreInfo) XXX_Unmarshal(b []byte) error

type TSDBInfo added in v0.32.0 

type TSDBInfo struct {
	Labels  labelpb.ZLabelSet `protobuf:"bytes,1,opt,name=labels,proto3" json:"labels"`
	MinTime int64             `protobuf:"varint,2,opt,name=min_time,json=minTime,proto3" json:"min_time,omitempty"`
	MaxTime int64             `protobuf:"varint,3,opt,name=max_time,json=maxTime,proto3" json:"max_time,omitempty"`
}

func NewTSDBInfo added in v0.32.0 

func NewTSDBInfo(mint, maxt int64, lbls []labelpb.ZLabel) TSDBInfo

func (*TSDBInfo) Descriptor added in v0.32.0 

func (*TSDBInfo) Descriptor() ([]byte, []int)

func (*TSDBInfo) Marshal added in v0.32.0 

func (m *TSDBInfo) Marshal() (dAtA []byte, err error)

func (*TSDBInfo) MarshalTo added in v0.32.0 

func (m *TSDBInfo) MarshalTo(dAtA []byte) (int, error)

func (*TSDBInfo) MarshalToSizedBuffer added in v0.32.0 

func (m *TSDBInfo) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*TSDBInfo) ProtoMessage added in v0.32.0 

func (*TSDBInfo) ProtoMessage()

func (*TSDBInfo) Reset added in v0.32.0 

func (m *TSDBInfo) Reset()

func (*TSDBInfo) Size added in v0.32.0 

func (m *TSDBInfo) Size() (n int)

func (*TSDBInfo) String added in v0.32.0 

func (m *TSDBInfo) String() string

func (*TSDBInfo) Unmarshal added in v0.32.0 

func (m *TSDBInfo) Unmarshal(dAtA []byte) error

func (*TSDBInfo) XXX_DiscardUnknown added in v0.32.0 

func (m *TSDBInfo) XXX_DiscardUnknown()

func (*TSDBInfo) XXX_Marshal added in v0.32.0 

func (m *TSDBInfo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*TSDBInfo) XXX_Merge added in v0.32.0 

func (m *TSDBInfo) XXX_Merge(src proto.Message)

func (*TSDBInfo) XXX_Size added in v0.32.0 

func (m *TSDBInfo) XXX_Size() int

func (*TSDBInfo) XXX_Unmarshal added in v0.32.0 

func (m *TSDBInfo) XXX_Unmarshal(b []byte) error

type TSDBInfos added in v0.32.0 

type TSDBInfos []TSDBInfo

func (TSDBInfos) LabelSets added in v0.32.0 

func (infos TSDBInfos) LabelSets() []labels.Labels

func (TSDBInfos) MaxT added in v0.32.0 

func (infos TSDBInfos) MaxT() int64

type TargetsInfo 

type TargetsInfo struct {
}

TargetsInfo holds the metadata related to Targets API exposed by the component.

func (*TargetsInfo) Descriptor 

func (*TargetsInfo) Descriptor() ([]byte, []int)

func (*TargetsInfo) Marshal 

func (m *TargetsInfo) Marshal() (dAtA []byte, err error)

func (*TargetsInfo) MarshalTo 

func (m *TargetsInfo) MarshalTo(dAtA []byte) (int, error)

func (*TargetsInfo) MarshalToSizedBuffer 

func (m *TargetsInfo) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*TargetsInfo) ProtoMessage 

func (*TargetsInfo) ProtoMessage()

func (*TargetsInfo) Reset 

func (m *TargetsInfo) Reset()

func (*TargetsInfo) Size 

func (m *TargetsInfo) Size() (n int)

func (*TargetsInfo) String 

func (m *TargetsInfo) String() string

func (*TargetsInfo) Unmarshal 

func (m *TargetsInfo) Unmarshal(dAtA []byte) error

func (*TargetsInfo) XXX_DiscardUnknown 

func (m *TargetsInfo) XXX_DiscardUnknown()

func (*TargetsInfo) XXX_Marshal 

func (m *TargetsInfo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*TargetsInfo) XXX_Merge 

func (m *TargetsInfo) XXX_Merge(src proto.Message)

func (*TargetsInfo) XXX_Size 

func (m *TargetsInfo) XXX_Size() int

func (*TargetsInfo) XXX_Unmarshal 

func (m *TargetsInfo) XXX_Unmarshal(b []byte) error

type UnimplementedInfoServer 

type UnimplementedInfoServer struct {
}

UnimplementedInfoServer can be embedded to have forward compatible implementations.

func (*UnimplementedInfoServer) Info 

func (*UnimplementedInfoServer) Info(ctx context.Context, req *InfoRequest) (*InfoResponse, error)

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.