conduit_public

package
v0.1.2 Latest Latest
Warning

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

 Go to latest Published: Jan 19, 2018 License: Apache-2.0 Imports: 8 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)
	SelfCheck(ctx context.Context, in *conduit_common_healthcheck.SelfCheckRequest, opts ...grpc.CallOption) (*conduit_common_healthcheck.SelfCheckResponse, 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 ApiServer 

type ApiServer interface {
	Stat(context.Context, *MetricRequest) (*MetricResponse, error)
	Version(context.Context, *Empty) (*VersionInfo, error)
	ListPods(context.Context, *Empty) (*ListPodsResponse, error)
	SelfCheck(context.Context, *conduit_common_healthcheck.SelfCheckRequest) (*conduit_common_healthcheck.SelfCheckResponse, error)
	Tap(*TapRequest, Api_TapServer) error
}

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

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.