conduit_public

package
v0.4.0 Latest Latest
Warning

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

Go to latest
Published: Apr 16, 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:

Empty
VersionInfo
ListPodsResponse
Pod
TapRequest
ApiError
Resource
ResourceSelection
ResourceError
StatSummaryRequest
StatSummaryResponse
BasicStats
StatTable

Index

Constants

This section is empty.

Variables

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 ApiClient

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 BasicStats added in v0.4.0

type BasicStats struct {
	SuccessCount uint64 `protobuf:"varint,1,opt,name=success_count,json=successCount" json:"success_count,omitempty"`
	FailureCount uint64 `protobuf:"varint,2,opt,name=failure_count,json=failureCount" json:"failure_count,omitempty"`
	LatencyMsP50 uint64 `protobuf:"varint,3,opt,name=latency_ms_p50,json=latencyMsP50" json:"latency_ms_p50,omitempty"`
	LatencyMsP95 uint64 `protobuf:"varint,4,opt,name=latency_ms_p95,json=latencyMsP95" json:"latency_ms_p95,omitempty"`
	LatencyMsP99 uint64 `protobuf:"varint,5,opt,name=latency_ms_p99,json=latencyMsP99" json:"latency_ms_p99,omitempty"`
}

func (*BasicStats) Descriptor added in v0.4.0

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

func (*BasicStats) GetFailureCount added in v0.4.0

func (m *BasicStats) GetFailureCount() uint64

func (*BasicStats) GetLatencyMsP50 added in v0.4.0

func (m *BasicStats) GetLatencyMsP50() uint64

func (*BasicStats) GetLatencyMsP95 added in v0.4.0

func (m *BasicStats) GetLatencyMsP95() uint64

func (*BasicStats) GetLatencyMsP99 added in v0.4.0

func (m *BasicStats) GetLatencyMsP99() uint64

func (*BasicStats) GetSuccessCount added in v0.4.0

func (m *BasicStats) GetSuccessCount() uint64

func (*BasicStats) ProtoMessage added in v0.4.0

func (*BasicStats) ProtoMessage()

func (*BasicStats) Reset added in v0.4.0

func (m *BasicStats) Reset()

func (*BasicStats) String added in v0.4.0

func (m *BasicStats) String() string

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 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 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 Resource added in v0.4.0

type Resource struct {
	Namespace string `protobuf:"bytes,1,opt,name=namespace" json:"namespace,omitempty"`
	Type      string `protobuf:"bytes,2,opt,name=type" json:"type,omitempty"`
	Name      string `protobuf:"bytes,3,opt,name=name" json:"name,omitempty"`
}

func (*Resource) Descriptor added in v0.4.0

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

func (*Resource) GetName added in v0.4.0

func (m *Resource) GetName() string

func (*Resource) GetNamespace added in v0.4.0

func (m *Resource) GetNamespace() string

func (*Resource) GetType added in v0.4.0

func (m *Resource) GetType() string

func (*Resource) ProtoMessage added in v0.4.0

func (*Resource) ProtoMessage()

func (*Resource) Reset added in v0.4.0

func (m *Resource) Reset()

func (*Resource) String added in v0.4.0

func (m *Resource) String() string

type ResourceError added in v0.4.0

type ResourceError struct {
	Resource *Resource `protobuf:"bytes,1,opt,name=resource" json:"resource,omitempty"`
	Error    string    `protobuf:"bytes,2,opt,name=error" json:"error,omitempty"`
}

func (*ResourceError) Descriptor added in v0.4.0

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

func (*ResourceError) GetError added in v0.4.0

func (m *ResourceError) GetError() string

func (*ResourceError) GetResource added in v0.4.0

func (m *ResourceError) GetResource() *Resource

func (*ResourceError) ProtoMessage added in v0.4.0

func (*ResourceError) ProtoMessage()

func (*ResourceError) Reset added in v0.4.0

func (m *ResourceError) Reset()

func (*ResourceError) String added in v0.4.0

func (m *ResourceError) String() string

type ResourceSelection added in v0.4.0

type ResourceSelection struct {
	Resource      *Resource `protobuf:"bytes,1,opt,name=resource" json:"resource,omitempty"`
	LabelSelector string    `protobuf:"bytes,2,opt,name=label_selector,json=labelSelector" json:"label_selector,omitempty"`
}

func (*ResourceSelection) Descriptor added in v0.4.0

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

func (*ResourceSelection) GetLabelSelector added in v0.4.0

func (m *ResourceSelection) GetLabelSelector() string

func (*ResourceSelection) GetResource added in v0.4.0

func (m *ResourceSelection) GetResource() *Resource

func (*ResourceSelection) ProtoMessage added in v0.4.0

func (*ResourceSelection) ProtoMessage()

func (*ResourceSelection) Reset added in v0.4.0

func (m *ResourceSelection) Reset()

func (*ResourceSelection) String added in v0.4.0

func (m *ResourceSelection) String() string

type StatSummaryRequest added in v0.4.0

type StatSummaryRequest struct {
	Selector   *ResourceSelection `protobuf:"bytes,1,opt,name=selector" json:"selector,omitempty"`
	TimeWindow TimeWindow         `protobuf:"varint,2,opt,name=time_window,json=timeWindow,enum=conduit.public.TimeWindow" json:"time_window,omitempty"`
	// Types that are valid to be assigned to Outbound:
	//	*StatSummaryRequest_None
	//	*StatSummaryRequest_ToResource
	//	*StatSummaryRequest_FromResource
	Outbound isStatSummaryRequest_Outbound `protobuf_oneof:"outbound"`
}

func (*StatSummaryRequest) Descriptor added in v0.4.0

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

func (*StatSummaryRequest) GetFromResource added in v0.4.0

func (m *StatSummaryRequest) GetFromResource() *Resource

func (*StatSummaryRequest) GetNone added in v0.4.0

func (m *StatSummaryRequest) GetNone() *Empty

func (*StatSummaryRequest) GetOutbound added in v0.4.0

func (m *StatSummaryRequest) GetOutbound() isStatSummaryRequest_Outbound

func (*StatSummaryRequest) GetSelector added in v0.4.0

func (m *StatSummaryRequest) GetSelector() *ResourceSelection

func (*StatSummaryRequest) GetTimeWindow added in v0.4.0

func (m *StatSummaryRequest) GetTimeWindow() TimeWindow

func (*StatSummaryRequest) GetToResource added in v0.4.0

func (m *StatSummaryRequest) GetToResource() *Resource

func (*StatSummaryRequest) ProtoMessage added in v0.4.0

func (*StatSummaryRequest) ProtoMessage()

func (*StatSummaryRequest) Reset added in v0.4.0

func (m *StatSummaryRequest) Reset()

func (*StatSummaryRequest) String added in v0.4.0

func (m *StatSummaryRequest) String() string

func (*StatSummaryRequest) XXX_OneofFuncs added in v0.4.0

func (*StatSummaryRequest) 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 StatSummaryRequest_FromResource added in v0.4.0

type StatSummaryRequest_FromResource struct {
	FromResource *Resource `protobuf:"bytes,5,opt,name=from_resource,json=fromResource,oneof"`
}

type StatSummaryRequest_None added in v0.4.0

type StatSummaryRequest_None struct {
	None *Empty `protobuf:"bytes,3,opt,name=none,oneof"`
}

type StatSummaryRequest_ToResource added in v0.4.0

type StatSummaryRequest_ToResource struct {
	ToResource *Resource `protobuf:"bytes,4,opt,name=to_resource,json=toResource,oneof"`
}

type StatSummaryResponse added in v0.4.0

type StatSummaryResponse struct {
	// Types that are valid to be assigned to Response:
	//	*StatSummaryResponse_Ok_
	//	*StatSummaryResponse_Error
	Response isStatSummaryResponse_Response `protobuf_oneof:"response"`
}

func (*StatSummaryResponse) Descriptor added in v0.4.0

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

func (*StatSummaryResponse) GetError added in v0.4.0

func (m *StatSummaryResponse) GetError() *ResourceError

func (*StatSummaryResponse) GetOk added in v0.4.0

func (*StatSummaryResponse) GetResponse added in v0.4.0

func (m *StatSummaryResponse) GetResponse() isStatSummaryResponse_Response

func (*StatSummaryResponse) ProtoMessage added in v0.4.0

func (*StatSummaryResponse) ProtoMessage()

func (*StatSummaryResponse) Reset added in v0.4.0

func (m *StatSummaryResponse) Reset()

func (*StatSummaryResponse) String added in v0.4.0

func (m *StatSummaryResponse) String() string

func (*StatSummaryResponse) XXX_OneofFuncs added in v0.4.0

func (*StatSummaryResponse) 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 StatSummaryResponse_Error added in v0.4.0

type StatSummaryResponse_Error struct {
	Error *ResourceError `protobuf:"bytes,2,opt,name=error,oneof"`
}

type StatSummaryResponse_Ok added in v0.4.0

type StatSummaryResponse_Ok struct {
	StatTables []*StatTable `protobuf:"bytes,1,rep,name=stat_tables,json=statTables" json:"stat_tables,omitempty"`
}

func (*StatSummaryResponse_Ok) Descriptor added in v0.4.0

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

func (*StatSummaryResponse_Ok) GetStatTables added in v0.4.0

func (m *StatSummaryResponse_Ok) GetStatTables() []*StatTable

func (*StatSummaryResponse_Ok) ProtoMessage added in v0.4.0

func (*StatSummaryResponse_Ok) ProtoMessage()

func (*StatSummaryResponse_Ok) Reset added in v0.4.0

func (m *StatSummaryResponse_Ok) Reset()

func (*StatSummaryResponse_Ok) String added in v0.4.0

func (m *StatSummaryResponse_Ok) String() string

type StatSummaryResponse_Ok_ added in v0.4.0

type StatSummaryResponse_Ok_ struct {
	Ok *StatSummaryResponse_Ok `protobuf:"bytes,1,opt,name=ok,oneof"`
}

type StatTable added in v0.4.0

type StatTable struct {
	// Types that are valid to be assigned to Table:
	//	*StatTable_PodGroup_
	Table isStatTable_Table `protobuf_oneof:"table"`
}

func (*StatTable) Descriptor added in v0.4.0

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

func (*StatTable) GetPodGroup added in v0.4.0

func (m *StatTable) GetPodGroup() *StatTable_PodGroup

func (*StatTable) GetTable added in v0.4.0

func (m *StatTable) GetTable() isStatTable_Table

func (*StatTable) ProtoMessage added in v0.4.0

func (*StatTable) ProtoMessage()

func (*StatTable) Reset added in v0.4.0

func (m *StatTable) Reset()

func (*StatTable) String added in v0.4.0

func (m *StatTable) String() string

func (*StatTable) XXX_OneofFuncs added in v0.4.0

func (*StatTable) 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 StatTable_PodGroup added in v0.4.0

type StatTable_PodGroup struct {
	Rows []*StatTable_PodGroup_Row `protobuf:"bytes,1,rep,name=rows" json:"rows,omitempty"`
}

func (*StatTable_PodGroup) Descriptor added in v0.4.0

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

func (*StatTable_PodGroup) GetRows added in v0.4.0

func (*StatTable_PodGroup) ProtoMessage added in v0.4.0

func (*StatTable_PodGroup) ProtoMessage()

func (*StatTable_PodGroup) Reset added in v0.4.0

func (m *StatTable_PodGroup) Reset()

func (*StatTable_PodGroup) String added in v0.4.0

func (m *StatTable_PodGroup) String() string

type StatTable_PodGroup_ added in v0.4.0

type StatTable_PodGroup_ struct {
	PodGroup *StatTable_PodGroup `protobuf:"bytes,1,opt,name=pod_group,json=podGroup,oneof"`
}

type StatTable_PodGroup_Row added in v0.4.0

type StatTable_PodGroup_Row struct {
	Resource       *Resource   `protobuf:"bytes,1,opt,name=resource" json:"resource,omitempty"`
	TimeWindow     TimeWindow  `protobuf:"varint,2,opt,name=time_window,json=timeWindow,enum=conduit.public.TimeWindow" json:"time_window,omitempty"`
	MeshedPodCount uint64      `protobuf:"varint,3,opt,name=meshed_pod_count,json=meshedPodCount" json:"meshed_pod_count,omitempty"`
	TotalPodCount  uint64      `protobuf:"varint,4,opt,name=total_pod_count,json=totalPodCount" json:"total_pod_count,omitempty"`
	Stats          *BasicStats `protobuf:"bytes,5,opt,name=stats" json:"stats,omitempty"`
}

func (*StatTable_PodGroup_Row) Descriptor added in v0.4.0

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

func (*StatTable_PodGroup_Row) GetMeshedPodCount added in v0.4.0

func (m *StatTable_PodGroup_Row) GetMeshedPodCount() uint64

func (*StatTable_PodGroup_Row) GetResource added in v0.4.0

func (m *StatTable_PodGroup_Row) GetResource() *Resource

func (*StatTable_PodGroup_Row) GetStats added in v0.4.0

func (m *StatTable_PodGroup_Row) GetStats() *BasicStats

func (*StatTable_PodGroup_Row) GetTimeWindow added in v0.4.0

func (m *StatTable_PodGroup_Row) GetTimeWindow() TimeWindow

func (*StatTable_PodGroup_Row) GetTotalPodCount added in v0.4.0

func (m *StatTable_PodGroup_Row) GetTotalPodCount() uint64

func (*StatTable_PodGroup_Row) ProtoMessage added in v0.4.0

func (*StatTable_PodGroup_Row) ProtoMessage()

func (*StatTable_PodGroup_Row) Reset added in v0.4.0

func (m *StatTable_PodGroup_Row) Reset()

func (*StatTable_PodGroup_Row) String added in v0.4.0

func (m *StatTable_PodGroup_Row) 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