conduit_controller_telemetry

Documentation

Overview

Package conduit_controller_telemetry is a generated protocol buffer package.

It is generated from these files:

controller/telemetry/telemetry.proto

It has these top-level messages:

QueryRequest
QueryResponse
Sample
SampleValue
ListPodsRequest

Index

• func RegisterTelemetryServer(s *grpc.Server, srv TelemetryServer)
• type ListPodsRequest
  • func (*ListPodsRequest) Descriptor() ([]byte, []int)
  • func (*ListPodsRequest) ProtoMessage()
  • func (m *ListPodsRequest) Reset()
  • func (m *ListPodsRequest) String() string
• type QueryRequest
  • func (*QueryRequest) Descriptor() ([]byte, []int)
  • func (m *QueryRequest) GetEndMs() int64
  • func (m *QueryRequest) GetQuery() string
  • func (m *QueryRequest) GetStartMs() int64
  • func (m *QueryRequest) GetStep() string
  • func (*QueryRequest) ProtoMessage()
  • func (m *QueryRequest) Reset()
  • func (m *QueryRequest) String() string
• type QueryResponse
  • func (*QueryResponse) Descriptor() ([]byte, []int)
  • func (m *QueryResponse) GetMetrics() []*Sample
  • func (*QueryResponse) ProtoMessage()
  • func (m *QueryResponse) Reset()
  • func (m *QueryResponse) String() string
• type Sample
  • func (*Sample) Descriptor() ([]byte, []int)
  • func (m *Sample) GetLabels() map[string]string
  • func (m *Sample) GetValues() []*SampleValue
  • func (*Sample) ProtoMessage()
  • func (m *Sample) Reset()
  • func (m *Sample) String() string
• type SampleValue
  • func (*SampleValue) Descriptor() ([]byte, []int)
  • func (m *SampleValue) GetTimestampMs() int64
  • func (m *SampleValue) GetValue() float64
  • func (*SampleValue) ProtoMessage()
  • func (m *SampleValue) Reset()
  • func (m *SampleValue) String() string
• type TelemetryClient
  • func NewTelemetryClient(cc *grpc.ClientConn) TelemetryClient
• type TelemetryServer

Functions

func RegisterTelemetryServer

func RegisterTelemetryServer(s *grpc.Server, srv TelemetryServer)

Types

type ListPodsRequest

type ListPodsRequest struct {
}

func (*ListPodsRequest) Descriptor

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

func (*ListPodsRequest) ProtoMessage

func (*ListPodsRequest) ProtoMessage()

func (*ListPodsRequest) Reset

func (m *ListPodsRequest) Reset()

func (*ListPodsRequest) String

func (m *ListPodsRequest) String() string

type QueryRequest

type QueryRequest struct {
	Query   string `protobuf:"bytes,1,opt,name=query" json:"query,omitempty"`
	StartMs int64  `protobuf:"varint,2,opt,name=start_ms,json=startMs" json:"start_ms,omitempty"`
	EndMs   int64  `protobuf:"varint,3,opt,name=end_ms,json=endMs" json:"end_ms,omitempty"`
	Step    string `protobuf:"bytes,4,opt,name=step" json:"step,omitempty"`
}

func (*QueryRequest) Descriptor

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

func (*QueryRequest) GetEndMs

func (m *QueryRequest) GetEndMs() int64

func (*QueryRequest) GetQuery

func (m *QueryRequest) GetQuery() string

func (*QueryRequest) GetStartMs

func (m *QueryRequest) GetStartMs() int64

func (*QueryRequest) GetStep

func (m *QueryRequest) GetStep() string

func (*QueryRequest) ProtoMessage

func (*QueryRequest) ProtoMessage()

func (*QueryRequest) Reset

func (m *QueryRequest) Reset()

func (*QueryRequest) String

func (m *QueryRequest) String() string

type QueryResponse

type QueryResponse struct {
	Metrics []*Sample `protobuf:"bytes,1,rep,name=metrics" json:"metrics,omitempty"`
}

func (*QueryResponse) Descriptor

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

func (*QueryResponse) GetMetrics

func (m *QueryResponse) GetMetrics() []*Sample

func (*QueryResponse) ProtoMessage

func (*QueryResponse) ProtoMessage()

func (*QueryResponse) Reset

func (m *QueryResponse) Reset()

func (*QueryResponse) String

func (m *QueryResponse) String() string

type Sample

type Sample struct {
	Values []*SampleValue    `protobuf:"bytes,1,rep,name=values" json:"values,omitempty"`
	Labels map[string]string `` /* 132-byte string literal not displayed */
}

func (*Sample) Descriptor

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

func (*Sample) GetLabels

func (m *Sample) GetLabels() map[string]string

func (*Sample) GetValues

func (m *Sample) GetValues() []*SampleValue

func (*Sample) ProtoMessage

func (*Sample) ProtoMessage()

func (*Sample) Reset

func (m *Sample) Reset()

func (*Sample) String

func (m *Sample) String() string

type SampleValue

type SampleValue struct {
	Value       float64 `protobuf:"fixed64,1,opt,name=value" json:"value,omitempty"`
	TimestampMs int64   `protobuf:"varint,2,opt,name=timestamp_ms,json=timestampMs" json:"timestamp_ms,omitempty"`
}

func (*SampleValue) Descriptor

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

func (*SampleValue) GetTimestampMs

func (m *SampleValue) GetTimestampMs() int64

func (*SampleValue) GetValue

func (m *SampleValue) GetValue() float64

func (*SampleValue) ProtoMessage

func (*SampleValue) ProtoMessage()

func (*SampleValue) Reset

func (m *SampleValue) Reset()

func (*SampleValue) String

func (m *SampleValue) String() string

type TelemetryClient

type TelemetryClient interface {
	Query(ctx context.Context, in *QueryRequest, opts ...grpc.CallOption) (*QueryResponse, error)
	ListPods(ctx context.Context, in *ListPodsRequest, opts ...grpc.CallOption) (*conduit_public.ListPodsResponse, error)
}

func NewTelemetryClient

func NewTelemetryClient(cc *grpc.ClientConn) TelemetryClient

type TelemetryServer

type TelemetryServer interface {
	Query(context.Context, *QueryRequest) (*QueryResponse, error)
	ListPods(context.Context, *ListPodsRequest) (*conduit_public.ListPodsResponse, error)
}