Versions in this module Expand all Collapse all v0 v0.1.0 Dec 5, 2017 Changes in this version + var AggregationType_name = map[int32]string + var AggregationType_value = map[string]int32 + var HistogramLabel_name = map[int32]string + var HistogramLabel_value = map[string]int32 + var MetricName_name = map[int32]string + var MetricName_value = map[string]int32 + var TimeWindow_name = map[int32]string + var TimeWindow_value = map[string]int32 + func RegisterApiServer(s *grpc.Server, srv ApiServer) + type AggregationType int32 + const AggregationType_MESH + const AggregationType_SOURCE_DEPLOY + const AggregationType_SOURCE_POD + const AggregationType_TARGET_DEPLOY + const AggregationType_TARGET_POD + func (AggregationType) EnumDescriptor() ([]byte, []int) + func (x AggregationType) String() string + type ApiClient interface + ListPods func(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*ListPodsResponse, error) + Stat func(ctx context.Context, in *MetricRequest, opts ...grpc.CallOption) (*MetricResponse, error) + Tap func(ctx context.Context, in *TapRequest, opts ...grpc.CallOption) (Api_TapClient, error) + Version func(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*VersionInfo, error) + func NewApiClient(cc *grpc.ClientConn) ApiClient + type ApiServer interface + ListPods func(context.Context, *Empty) (*ListPodsResponse, error) + Stat func(context.Context, *MetricRequest) (*MetricResponse, error) + Tap func(*TapRequest, Api_TapServer) error + Version func(context.Context, *Empty) (*VersionInfo, error) + type Api_TapClient interface + Recv func() (*conduit_common.TapEvent, error) + type Api_TapServer interface + Send func(*conduit_common.TapEvent) error + type Empty struct + func (*Empty) Descriptor() ([]byte, []int) + func (*Empty) ProtoMessage() + func (m *Empty) Reset() + func (m *Empty) String() string + type Histogram struct + Values []*HistogramValue + func (*Histogram) Descriptor() ([]byte, []int) + func (*Histogram) ProtoMessage() + func (m *Histogram) GetValues() []*HistogramValue + func (m *Histogram) Reset() + func (m *Histogram) String() string + type HistogramLabel int32 + const HistogramLabel_MAX + const HistogramLabel_MIN + const HistogramLabel_P50 + const HistogramLabel_P95 + const HistogramLabel_P99 + func (HistogramLabel) EnumDescriptor() ([]byte, []int) + func (x HistogramLabel) String() string + type HistogramValue struct + Label HistogramLabel + Value int64 + func (*HistogramValue) Descriptor() ([]byte, []int) + func (*HistogramValue) ProtoMessage() + func (m *HistogramValue) GetLabel() HistogramLabel + func (m *HistogramValue) GetValue() int64 + func (m *HistogramValue) Reset() + func (m *HistogramValue) String() string + type ListPodsResponse struct + Pods []*Pod + func (*ListPodsResponse) Descriptor() ([]byte, []int) + func (*ListPodsResponse) ProtoMessage() + func (m *ListPodsResponse) GetPods() []*Pod + func (m *ListPodsResponse) Reset() + func (m *ListPodsResponse) String() string + type MetricDatapoint struct + TimestampMs int64 + Value *MetricValue + func (*MetricDatapoint) Descriptor() ([]byte, []int) + func (*MetricDatapoint) ProtoMessage() + func (m *MetricDatapoint) GetTimestampMs() int64 + func (m *MetricDatapoint) GetValue() *MetricValue + func (m *MetricDatapoint) Reset() + func (m *MetricDatapoint) String() string + type MetricMetadata struct + Component string + SourceDeploy string + SourcePod string + TargetDeploy string + TargetPod string + func (*MetricMetadata) Descriptor() ([]byte, []int) + func (*MetricMetadata) ProtoMessage() + func (m *MetricMetadata) GetComponent() string + func (m *MetricMetadata) GetSourceDeploy() string + func (m *MetricMetadata) GetSourcePod() string + func (m *MetricMetadata) GetTargetDeploy() string + func (m *MetricMetadata) GetTargetPod() string + func (m *MetricMetadata) Reset() + func (m *MetricMetadata) String() string + type MetricName int32 + const MetricName_LATENCY + const MetricName_REQUEST_RATE + const MetricName_SUCCESS_RATE + func (MetricName) EnumDescriptor() ([]byte, []int) + func (x MetricName) String() string + type MetricRequest struct + FilterBy *MetricMetadata + GroupBy AggregationType + Metrics []MetricName + Summarize bool + Window TimeWindow + func (*MetricRequest) Descriptor() ([]byte, []int) + func (*MetricRequest) ProtoMessage() + func (m *MetricRequest) GetFilterBy() *MetricMetadata + func (m *MetricRequest) GetGroupBy() AggregationType + func (m *MetricRequest) GetMetrics() []MetricName + func (m *MetricRequest) GetSummarize() bool + func (m *MetricRequest) GetWindow() TimeWindow + func (m *MetricRequest) Reset() + func (m *MetricRequest) String() string + type MetricResponse struct + Metrics []*MetricSeries + func (*MetricResponse) Descriptor() ([]byte, []int) + func (*MetricResponse) ProtoMessage() + func (m *MetricResponse) GetMetrics() []*MetricSeries + func (m *MetricResponse) Reset() + func (m *MetricResponse) String() string + type MetricSeries struct + Datapoints []*MetricDatapoint + Metadata *MetricMetadata + Name MetricName + func (*MetricSeries) Descriptor() ([]byte, []int) + func (*MetricSeries) ProtoMessage() + func (m *MetricSeries) GetDatapoints() []*MetricDatapoint + func (m *MetricSeries) GetMetadata() *MetricMetadata + func (m *MetricSeries) GetName() MetricName + func (m *MetricSeries) Reset() + func (m *MetricSeries) String() string + type MetricValue struct + Value isMetricValue_Value + func (*MetricValue) Descriptor() ([]byte, []int) + func (*MetricValue) ProtoMessage() + func (*MetricValue) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, ...) + func (m *MetricValue) GetCounter() int64 + func (m *MetricValue) GetGauge() float64 + func (m *MetricValue) GetHistogram() *Histogram + func (m *MetricValue) GetValue() isMetricValue_Value + func (m *MetricValue) Reset() + func (m *MetricValue) String() string + type MetricValue_Counter struct + Counter int64 + type MetricValue_Gauge struct + Gauge float64 + type MetricValue_Histogram struct + Histogram *Histogram + type Pod struct + Added bool + ControlPlane bool + ControllerNamespace string + Deployment string + Name string + PodIP string + SinceLastReport *google_protobuf.Duration + Status string + func (*Pod) Descriptor() ([]byte, []int) + func (*Pod) ProtoMessage() + func (m *Pod) GetAdded() bool + func (m *Pod) GetControlPlane() bool + func (m *Pod) GetControllerNamespace() string + func (m *Pod) GetDeployment() string + func (m *Pod) GetName() string + func (m *Pod) GetPodIP() string + func (m *Pod) GetSinceLastReport() *google_protobuf.Duration + func (m *Pod) GetStatus() string + func (m *Pod) Reset() + func (m *Pod) String() string + type TapRequest struct + Authority string + FromIP string + FromPort uint32 + MaxRps float32 + Method string + Path string + Scheme string + Target isTapRequest_Target + ToIP string + ToPort uint32 + func (*TapRequest) Descriptor() ([]byte, []int) + func (*TapRequest) ProtoMessage() + func (*TapRequest) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, ...) + func (m *TapRequest) GetAuthority() string + func (m *TapRequest) GetDeployment() string + func (m *TapRequest) GetFromIP() string + func (m *TapRequest) GetFromPort() uint32 + func (m *TapRequest) GetMaxRps() float32 + func (m *TapRequest) GetMethod() string + func (m *TapRequest) GetPath() string + func (m *TapRequest) GetPod() string + func (m *TapRequest) GetScheme() string + func (m *TapRequest) GetTarget() isTapRequest_Target + func (m *TapRequest) GetToIP() string + func (m *TapRequest) GetToPort() uint32 + func (m *TapRequest) Reset() + func (m *TapRequest) String() string + type TapRequest_Deployment struct + Deployment string + type TapRequest_Pod struct + Pod string + type TimeWindow int32 + const TimeWindow_ONE_HOUR + const TimeWindow_ONE_MIN + const TimeWindow_TEN_MIN + const TimeWindow_TEN_SEC + func (TimeWindow) EnumDescriptor() ([]byte, []int) + func (x TimeWindow) String() string + type VersionInfo struct + BuildDate string + GoVersion string + ReleaseVersion string + func (*VersionInfo) Descriptor() ([]byte, []int) + func (*VersionInfo) ProtoMessage() + func (m *VersionInfo) GetBuildDate() string + func (m *VersionInfo) GetGoVersion() string + func (m *VersionInfo) GetReleaseVersion() string + func (m *VersionInfo) Reset() + func (m *VersionInfo) String() string
Go to main page