conduit_public

package
v0.1.1 Latest Latest
Warning

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

Go to latest
Published: Dec 20, 2017 License: Apache-2.0 Imports: 7 Imported by: 0

Documentation

Overview

Package conduit_public is a generated protocol buffer package.

It is generated from these files:

public/api.proto

It has these top-level messages:

HistogramValue
Histogram
MetricValue
MetricDatapoint
MetricSeries
MetricMetadata
MetricResponse
MetricRequest
Empty
VersionInfo
ListPodsResponse
Pod
TapRequest
ApiError

Index

Constants

This section is empty.

Variables

View Source
var AggregationType_name = map[int32]string{
	0: "TARGET_POD",
	1: "TARGET_DEPLOY",
	2: "SOURCE_POD",
	3: "SOURCE_DEPLOY",
	4: "MESH",
	5: "PATH",
}
View Source
var AggregationType_value = map[string]int32{
	"TARGET_POD":    0,
	"TARGET_DEPLOY": 1,
	"SOURCE_POD":    2,
	"SOURCE_DEPLOY": 3,
	"MESH":          4,
	"PATH":          5,
}
View Source
var HistogramLabel_name = map[int32]string{
	0: "MIN",
	1: "P50",
	2: "P95",
	3: "P99",
	4: "MAX",
}
View Source
var HistogramLabel_value = map[string]int32{
	"MIN": 0,
	"P50": 1,
	"P95": 2,
	"P99": 3,
	"MAX": 4,
}
View Source
var MetricName_name = map[int32]string{
	0: "REQUEST_RATE",
	1: "LATENCY",
	2: "SUCCESS_RATE",
}
View Source
var MetricName_value = map[string]int32{
	"REQUEST_RATE": 0,
	"LATENCY":      1,
	"SUCCESS_RATE": 2,
}
View Source
var TimeWindow_name = map[int32]string{
	0: "TEN_SEC",
	1: "ONE_MIN",
	2: "TEN_MIN",
	3: "ONE_HOUR",
}
View Source
var TimeWindow_value = map[string]int32{
	"TEN_SEC":  0,
	"ONE_MIN":  1,
	"TEN_MIN":  2,
	"ONE_HOUR": 3,
}

Functions

func RegisterApiServer

func RegisterApiServer(s *grpc.Server, srv ApiServer)

Types

type AggregationType

type AggregationType int32
const (
	AggregationType_TARGET_POD    AggregationType = 0
	AggregationType_TARGET_DEPLOY AggregationType = 1
	AggregationType_SOURCE_POD    AggregationType = 2
	AggregationType_SOURCE_DEPLOY AggregationType = 3
	AggregationType_MESH          AggregationType = 4
	AggregationType_PATH          AggregationType = 5
)

func (AggregationType) EnumDescriptor

func (AggregationType) EnumDescriptor() ([]byte, []int)

func (AggregationType) String

func (x AggregationType) String() string

type ApiClient

type ApiClient interface {
	Stat(ctx context.Context, in *MetricRequest, opts ...grpc.CallOption) (*MetricResponse, error)
	Version(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*VersionInfo, error)
	ListPods(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*ListPodsResponse, error)
	Tap(ctx context.Context, in *TapRequest, opts ...grpc.CallOption) (Api_TapClient, error)
}

func NewApiClient

func NewApiClient(cc *grpc.ClientConn) ApiClient

type ApiError added in v0.1.1

type ApiError struct {
	Error string `protobuf:"bytes,1,opt,name=error" json:"error,omitempty"`
}

func (*ApiError) Descriptor added in v0.1.1

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

func (*ApiError) GetError added in v0.1.1

func (m *ApiError) GetError() string

func (*ApiError) ProtoMessage added in v0.1.1

func (*ApiError) ProtoMessage()

func (*ApiError) Reset added in v0.1.1

func (m *ApiError) Reset()

func (*ApiError) String added in v0.1.1

func (m *ApiError) String() string

type Api_TapClient

type Api_TapClient interface {
	Recv() (*conduit_common.TapEvent, error)
	grpc.ClientStream
}

type Api_TapServer

type Api_TapServer interface {
	Send(*conduit_common.TapEvent) error
	grpc.ServerStream
}

type Empty

type Empty struct {
}

func (*Empty) Descriptor

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

func (*Empty) ProtoMessage

func (*Empty) ProtoMessage()

func (*Empty) Reset

func (m *Empty) Reset()

func (*Empty) String

func (m *Empty) String() string

type Histogram

type Histogram struct {
	Values []*HistogramValue `protobuf:"bytes,1,rep,name=values" json:"values,omitempty"`
}

func (*Histogram) Descriptor

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

func (*Histogram) GetValues

func (m *Histogram) GetValues() []*HistogramValue

func (*Histogram) ProtoMessage

func (*Histogram) ProtoMessage()

func (*Histogram) Reset

func (m *Histogram) Reset()

func (*Histogram) String

func (m *Histogram) String() string

type HistogramLabel

type HistogramLabel int32
const (
	HistogramLabel_MIN HistogramLabel = 0
	HistogramLabel_P50 HistogramLabel = 1
	HistogramLabel_P95 HistogramLabel = 2
	HistogramLabel_P99 HistogramLabel = 3
	HistogramLabel_MAX HistogramLabel = 4
)

func (HistogramLabel) EnumDescriptor

func (HistogramLabel) EnumDescriptor() ([]byte, []int)

func (HistogramLabel) String

func (x HistogramLabel) String() string

type HistogramValue

type HistogramValue struct {
	Label HistogramLabel `protobuf:"varint,1,opt,name=label,enum=conduit.public.HistogramLabel" json:"label,omitempty"`
	Value int64          `protobuf:"varint,2,opt,name=value" json:"value,omitempty"`
}

func (*HistogramValue) Descriptor

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

func (*HistogramValue) GetLabel

func (m *HistogramValue) GetLabel() HistogramLabel

func (*HistogramValue) GetValue

func (m *HistogramValue) GetValue() int64

func (*HistogramValue) ProtoMessage

func (*HistogramValue) ProtoMessage()

func (*HistogramValue) Reset

func (m *HistogramValue) Reset()

func (*HistogramValue) String

func (m *HistogramValue) String() string

type ListPodsResponse

type ListPodsResponse struct {
	Pods []*Pod `protobuf:"bytes,1,rep,name=pods" json:"pods,omitempty"`
}

func (*ListPodsResponse) Descriptor

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

func (*ListPodsResponse) GetPods

func (m *ListPodsResponse) GetPods() []*Pod

func (*ListPodsResponse) ProtoMessage

func (*ListPodsResponse) ProtoMessage()

func (*ListPodsResponse) Reset

func (m *ListPodsResponse) Reset()

func (*ListPodsResponse) String

func (m *ListPodsResponse) String() string

type MetricDatapoint

type MetricDatapoint struct {
	Value       *MetricValue `protobuf:"bytes,1,opt,name=value" json:"value,omitempty"`
	TimestampMs int64        `protobuf:"varint,2,opt,name=timestamp_ms,json=timestampMs" json:"timestamp_ms,omitempty"`
}

func (*MetricDatapoint) Descriptor

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

func (*MetricDatapoint) GetTimestampMs

func (m *MetricDatapoint) GetTimestampMs() int64

func (*MetricDatapoint) GetValue

func (m *MetricDatapoint) GetValue() *MetricValue

func (*MetricDatapoint) ProtoMessage

func (*MetricDatapoint) ProtoMessage()

func (*MetricDatapoint) Reset

func (m *MetricDatapoint) Reset()

func (*MetricDatapoint) String

func (m *MetricDatapoint) String() string

type MetricMetadata

type MetricMetadata struct {
	TargetPod    string `protobuf:"bytes,1,opt,name=targetPod" json:"targetPod,omitempty"`
	TargetDeploy string `protobuf:"bytes,2,opt,name=targetDeploy" json:"targetDeploy,omitempty"`
	SourcePod    string `protobuf:"bytes,3,opt,name=sourcePod" json:"sourcePod,omitempty"`
	SourceDeploy string `protobuf:"bytes,4,opt,name=sourceDeploy" json:"sourceDeploy,omitempty"`
	Component    string `protobuf:"bytes,5,opt,name=component" json:"component,omitempty"`
	Path         string `protobuf:"bytes,6,opt,name=path" json:"path,omitempty"`
}

func (*MetricMetadata) Descriptor

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

func (*MetricMetadata) GetComponent

func (m *MetricMetadata) GetComponent() string

func (*MetricMetadata) GetPath added in v0.1.1

func (m *MetricMetadata) GetPath() string

func (*MetricMetadata) GetSourceDeploy

func (m *MetricMetadata) GetSourceDeploy() string

func (*MetricMetadata) GetSourcePod

func (m *MetricMetadata) GetSourcePod() string

func (*MetricMetadata) GetTargetDeploy

func (m *MetricMetadata) GetTargetDeploy() string

func (*MetricMetadata) GetTargetPod

func (m *MetricMetadata) GetTargetPod() string

func (*MetricMetadata) ProtoMessage

func (*MetricMetadata) ProtoMessage()

func (*MetricMetadata) Reset

func (m *MetricMetadata) Reset()

func (*MetricMetadata) String

func (m *MetricMetadata) String() string

type MetricName

type MetricName int32
const (
	MetricName_REQUEST_RATE MetricName = 0
	MetricName_LATENCY      MetricName = 1
	MetricName_SUCCESS_RATE MetricName = 2
)

func (MetricName) EnumDescriptor

func (MetricName) EnumDescriptor() ([]byte, []int)

func (MetricName) String

func (x MetricName) String() string

type MetricRequest

type MetricRequest struct {
	Metrics   []MetricName    `protobuf:"varint,1,rep,packed,name=metrics,enum=conduit.public.MetricName" json:"metrics,omitempty"`
	Window    TimeWindow      `protobuf:"varint,2,opt,name=window,enum=conduit.public.TimeWindow" json:"window,omitempty"`
	GroupBy   AggregationType `protobuf:"varint,3,opt,name=groupBy,enum=conduit.public.AggregationType" json:"groupBy,omitempty"`
	FilterBy  *MetricMetadata `protobuf:"bytes,4,opt,name=filterBy" json:"filterBy,omitempty"`
	Summarize bool            `protobuf:"varint,5,opt,name=summarize" json:"summarize,omitempty"`
}

func (*MetricRequest) Descriptor

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

func (*MetricRequest) GetFilterBy

func (m *MetricRequest) GetFilterBy() *MetricMetadata

func (*MetricRequest) GetGroupBy

func (m *MetricRequest) GetGroupBy() AggregationType

func (*MetricRequest) GetMetrics

func (m *MetricRequest) GetMetrics() []MetricName

func (*MetricRequest) GetSummarize

func (m *MetricRequest) GetSummarize() bool

func (*MetricRequest) GetWindow

func (m *MetricRequest) GetWindow() TimeWindow

func (*MetricRequest) ProtoMessage

func (*MetricRequest) ProtoMessage()

func (*MetricRequest) Reset

func (m *MetricRequest) Reset()

func (*MetricRequest) String

func (m *MetricRequest) String() string

type MetricResponse

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

func (*MetricResponse) Descriptor

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

func (*MetricResponse) GetMetrics

func (m *MetricResponse) GetMetrics() []*MetricSeries

func (*MetricResponse) ProtoMessage

func (*MetricResponse) ProtoMessage()

func (*MetricResponse) Reset

func (m *MetricResponse) Reset()

func (*MetricResponse) String

func (m *MetricResponse) String() string

type MetricSeries

type MetricSeries struct {
	Name       MetricName         `protobuf:"varint,1,opt,name=name,enum=conduit.public.MetricName" json:"name,omitempty"`
	Metadata   *MetricMetadata    `protobuf:"bytes,2,opt,name=metadata" json:"metadata,omitempty"`
	Datapoints []*MetricDatapoint `protobuf:"bytes,3,rep,name=datapoints" json:"datapoints,omitempty"`
}

func (*MetricSeries) Descriptor

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

func (*MetricSeries) GetDatapoints

func (m *MetricSeries) GetDatapoints() []*MetricDatapoint

func (*MetricSeries) GetMetadata

func (m *MetricSeries) GetMetadata() *MetricMetadata

func (*MetricSeries) GetName

func (m *MetricSeries) GetName() MetricName

func (*MetricSeries) ProtoMessage

func (*MetricSeries) ProtoMessage()

func (*MetricSeries) Reset

func (m *MetricSeries) Reset()

func (*MetricSeries) String

func (m *MetricSeries) String() string

type MetricValue

type MetricValue struct {
	// Types that are valid to be assigned to Value:
	//	*MetricValue_Counter
	//	*MetricValue_Gauge
	//	*MetricValue_Histogram
	Value isMetricValue_Value `protobuf_oneof:"value"`
}

func (*MetricValue) Descriptor

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

func (*MetricValue) GetCounter

func (m *MetricValue) GetCounter() int64

func (*MetricValue) GetGauge

func (m *MetricValue) GetGauge() float64

func (*MetricValue) GetHistogram

func (m *MetricValue) GetHistogram() *Histogram

func (*MetricValue) GetValue

func (m *MetricValue) GetValue() isMetricValue_Value

func (*MetricValue) ProtoMessage

func (*MetricValue) ProtoMessage()

func (*MetricValue) Reset

func (m *MetricValue) Reset()

func (*MetricValue) String

func (m *MetricValue) String() string

func (*MetricValue) XXX_OneofFuncs

func (*MetricValue) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, func(msg proto.Message, tag, wire int, b *proto.Buffer) (bool, error), func(msg proto.Message) (n int), []interface{})

XXX_OneofFuncs is for the internal use of the proto package.

type MetricValue_Counter

type MetricValue_Counter struct {
	Counter int64 `protobuf:"varint,1,opt,name=counter,oneof"`
}

type MetricValue_Gauge

type MetricValue_Gauge struct {
	Gauge float64 `protobuf:"fixed64,2,opt,name=gauge,oneof"`
}

type MetricValue_Histogram

type MetricValue_Histogram struct {
	Histogram *Histogram `protobuf:"bytes,3,opt,name=histogram,oneof"`
}

type Pod

type Pod struct {
	Name                string                    `protobuf:"bytes,1,opt,name=name" json:"name,omitempty"`
	PodIP               string                    `protobuf:"bytes,2,opt,name=podIP" json:"podIP,omitempty"`
	Deployment          string                    `protobuf:"bytes,3,opt,name=deployment" json:"deployment,omitempty"`
	Status              string                    `protobuf:"bytes,4,opt,name=status" json:"status,omitempty"`
	Added               bool                      `protobuf:"varint,5,opt,name=added" json:"added,omitempty"`
	SinceLastReport     *google_protobuf.Duration `protobuf:"bytes,6,opt,name=sinceLastReport" json:"sinceLastReport,omitempty"`
	ControllerNamespace string                    `protobuf:"bytes,7,opt,name=controllerNamespace" json:"controllerNamespace,omitempty"`
	ControlPlane        bool                      `protobuf:"varint,8,opt,name=controlPlane" json:"controlPlane,omitempty"`
}

func (*Pod) Descriptor

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

func (*Pod) GetAdded

func (m *Pod) GetAdded() bool

func (*Pod) GetControlPlane

func (m *Pod) GetControlPlane() bool

func (*Pod) GetControllerNamespace

func (m *Pod) GetControllerNamespace() string

func (*Pod) GetDeployment

func (m *Pod) GetDeployment() string

func (*Pod) GetName

func (m *Pod) GetName() string

func (*Pod) GetPodIP

func (m *Pod) GetPodIP() string

func (*Pod) GetSinceLastReport

func (m *Pod) GetSinceLastReport() *google_protobuf.Duration

func (*Pod) GetStatus

func (m *Pod) GetStatus() string

func (*Pod) ProtoMessage

func (*Pod) ProtoMessage()

func (*Pod) Reset

func (m *Pod) Reset()

func (*Pod) String

func (m *Pod) String() string

type TapRequest

type TapRequest struct {
	// Types that are valid to be assigned to Target:
	//	*TapRequest_Pod
	//	*TapRequest_Deployment
	Target isTapRequest_Target `protobuf_oneof:"target"`
	// validation of these fields happens on the server
	MaxRps    float32 `protobuf:"fixed32,3,opt,name=maxRps" json:"maxRps,omitempty"`
	ToPort    uint32  `protobuf:"varint,4,opt,name=toPort" json:"toPort,omitempty"`
	ToIP      string  `protobuf:"bytes,5,opt,name=toIP" json:"toIP,omitempty"`
	FromPort  uint32  `protobuf:"varint,6,opt,name=fromPort" json:"fromPort,omitempty"`
	FromIP    string  `protobuf:"bytes,7,opt,name=fromIP" json:"fromIP,omitempty"`
	Scheme    string  `protobuf:"bytes,8,opt,name=scheme" json:"scheme,omitempty"`
	Method    string  `protobuf:"bytes,9,opt,name=method" json:"method,omitempty"`
	Authority string  `protobuf:"bytes,10,opt,name=authority" json:"authority,omitempty"`
	Path      string  `protobuf:"bytes,11,opt,name=path" json:"path,omitempty"`
}

func (*TapRequest) Descriptor

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

func (*TapRequest) GetAuthority

func (m *TapRequest) GetAuthority() string

func (*TapRequest) GetDeployment

func (m *TapRequest) GetDeployment() string

func (*TapRequest) GetFromIP

func (m *TapRequest) GetFromIP() string

func (*TapRequest) GetFromPort

func (m *TapRequest) GetFromPort() uint32

func (*TapRequest) GetMaxRps

func (m *TapRequest) GetMaxRps() float32

func (*TapRequest) GetMethod

func (m *TapRequest) GetMethod() string

func (*TapRequest) GetPath

func (m *TapRequest) GetPath() string

func (*TapRequest) GetPod

func (m *TapRequest) GetPod() string

func (*TapRequest) GetScheme

func (m *TapRequest) GetScheme() string

func (*TapRequest) GetTarget

func (m *TapRequest) GetTarget() isTapRequest_Target

func (*TapRequest) GetToIP

func (m *TapRequest) GetToIP() string

func (*TapRequest) GetToPort

func (m *TapRequest) GetToPort() uint32

func (*TapRequest) ProtoMessage

func (*TapRequest) ProtoMessage()

func (*TapRequest) Reset

func (m *TapRequest) Reset()

func (*TapRequest) String

func (m *TapRequest) String() string

func (*TapRequest) XXX_OneofFuncs

func (*TapRequest) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, func(msg proto.Message, tag, wire int, b *proto.Buffer) (bool, error), func(msg proto.Message) (n int), []interface{})

XXX_OneofFuncs is for the internal use of the proto package.

type TapRequest_Deployment

type TapRequest_Deployment struct {
	Deployment string `protobuf:"bytes,2,opt,name=deployment,oneof"`
}

type TapRequest_Pod

type TapRequest_Pod struct {
	Pod string `protobuf:"bytes,1,opt,name=pod,oneof"`
}

type TimeWindow

type TimeWindow int32
const (
	TimeWindow_TEN_SEC  TimeWindow = 0
	TimeWindow_ONE_MIN  TimeWindow = 1
	TimeWindow_TEN_MIN  TimeWindow = 2
	TimeWindow_ONE_HOUR TimeWindow = 3
)

func (TimeWindow) EnumDescriptor

func (TimeWindow) EnumDescriptor() ([]byte, []int)

func (TimeWindow) String

func (x TimeWindow) String() string

type VersionInfo

type VersionInfo struct {
	GoVersion      string `protobuf:"bytes,1,opt,name=goVersion" json:"goVersion,omitempty"`
	BuildDate      string `protobuf:"bytes,2,opt,name=buildDate" json:"buildDate,omitempty"`
	ReleaseVersion string `protobuf:"bytes,3,opt,name=releaseVersion" json:"releaseVersion,omitempty"`
}

func (*VersionInfo) Descriptor

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

func (*VersionInfo) GetBuildDate

func (m *VersionInfo) GetBuildDate() string

func (*VersionInfo) GetGoVersion

func (m *VersionInfo) GetGoVersion() string

func (*VersionInfo) GetReleaseVersion

func (m *VersionInfo) GetReleaseVersion() string

func (*VersionInfo) ProtoMessage

func (*VersionInfo) ProtoMessage()

func (*VersionInfo) Reset

func (m *VersionInfo) Reset()

func (*VersionInfo) String

func (m *VersionInfo) String() string

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL