public

package
v0.5.0 Latest Latest
Warning

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

 Go to latest Published: Jul 5, 2018 License: Apache-2.0 Imports: 8 Imported by: 0

Documentation

Overview

Package public is a generated protocol buffer package.

It is generated from these files: 

public.proto

It has these top-level messages: 

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

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func RegisterApiServer 

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

Types

type ApiClient 

type ApiClient interface {
	StatSummary(ctx context.Context, in *StatSummaryRequest, opts ...grpc.CallOption) (*StatSummaryResponse, error)
	ListPods(ctx context.Context, in *ListPodsRequest, opts ...grpc.CallOption) (*ListPodsResponse, error)
	// Superceded by `TapByResource`.
	Tap(ctx context.Context, in *TapRequest, opts ...grpc.CallOption) (Api_TapClient, error)
	// Executes tapping over Kubernetes resources.
	TapByResource(ctx context.Context, in *TapByResourceRequest, opts ...grpc.CallOption) (Api_TapByResourceClient, error)
	Version(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*VersionInfo, error)
	SelfCheck(ctx context.Context, in *conduit_common_healthcheck.SelfCheckRequest, opts ...grpc.CallOption) (*conduit_common_healthcheck.SelfCheckResponse, error)
}

func NewApiClient 

func NewApiClient(cc *grpc.ClientConn) ApiClient

type ApiError 

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

func (*ApiError) Descriptor 

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

func (*ApiError) GetError 

func (m *ApiError) GetError() string

func (*ApiError) ProtoMessage 

func (*ApiError) ProtoMessage()

func (*ApiError) Reset 

func (m *ApiError) Reset()

func (*ApiError) String 

func (m *ApiError) String() string

type ApiServer 

type ApiServer interface {
	StatSummary(context.Context, *StatSummaryRequest) (*StatSummaryResponse, error)
	ListPods(context.Context, *ListPodsRequest) (*ListPodsResponse, error)
	// Superceded by `TapByResource`.
	Tap(*TapRequest, Api_TapServer) error
	// Executes tapping over Kubernetes resources.
	TapByResource(*TapByResourceRequest, Api_TapByResourceServer) error
	Version(context.Context, *Empty) (*VersionInfo, error)
	SelfCheck(context.Context, *conduit_common_healthcheck.SelfCheckRequest) (*conduit_common_healthcheck.SelfCheckResponse, error)
}

type Api_TapByResourceClient 

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

type Api_TapByResourceServer 

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

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 

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"`
	TlsRequestCount uint64 `protobuf:"varint,6,opt,name=tls_request_count,json=tlsRequestCount" json:"tls_request_count,omitempty"`
}

func (*BasicStats) Descriptor 

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

func (*BasicStats) GetFailureCount 

func (m *BasicStats) GetFailureCount() uint64

func (*BasicStats) GetLatencyMsP50 

func (m *BasicStats) GetLatencyMsP50() uint64

func (*BasicStats) GetLatencyMsP95 

func (m *BasicStats) GetLatencyMsP95() uint64

func (*BasicStats) GetLatencyMsP99 

func (m *BasicStats) GetLatencyMsP99() uint64

func (*BasicStats) GetSuccessCount 

func (m *BasicStats) GetSuccessCount() uint64

func (*BasicStats) GetTlsRequestCount 

func (m *BasicStats) GetTlsRequestCount() uint64

func (*BasicStats) ProtoMessage 

func (*BasicStats) ProtoMessage()

func (*BasicStats) Reset 

func (m *BasicStats) Reset()

func (*BasicStats) String 

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 ListPodsRequest 

type ListPodsRequest struct {
	Namespace string `protobuf:"bytes,1,opt,name=namespace" json:"namespace,omitempty"`
}

func (*ListPodsRequest) Descriptor 

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

func (*ListPodsRequest) GetNamespace 

func (m *ListPodsRequest) GetNamespace() string

func (*ListPodsRequest) ProtoMessage 

func (*ListPodsRequest) ProtoMessage()

func (*ListPodsRequest) Reset 

func (m *ListPodsRequest) Reset()

func (*ListPodsRequest) String 

func (m *ListPodsRequest) 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"`
	Uptime              *google_protobuf.Duration `protobuf:"bytes,9,opt,name=uptime" json:"uptime,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) GetUptime 

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

func (*Pod) ProtoMessage 

func (*Pod) ProtoMessage()

func (*Pod) Reset 

func (m *Pod) Reset()

func (*Pod) String 

func (m *Pod) String() string

type PodErrors 

type PodErrors struct {
	Errors []*PodErrors_PodError `protobuf:"bytes,1,rep,name=errors" json:"errors,omitempty"`
}

func (*PodErrors) Descriptor 

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

func (*PodErrors) GetErrors 

func (m *PodErrors) GetErrors() []*PodErrors_PodError

func (*PodErrors) ProtoMessage 

func (*PodErrors) ProtoMessage()

func (*PodErrors) Reset 

func (m *PodErrors) Reset()

func (*PodErrors) String 

func (m *PodErrors) String() string

type PodErrors_PodError 

type PodErrors_PodError struct {
	// Types that are valid to be assigned to Error:
	//	*PodErrors_PodError_Container
	Error isPodErrors_PodError_Error `protobuf_oneof:"error"`
}

func (*PodErrors_PodError) Descriptor 

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

func (*PodErrors_PodError) GetContainer 

func (m *PodErrors_PodError) GetContainer() *PodErrors_PodError_ContainerError

func (*PodErrors_PodError) GetError 

func (m *PodErrors_PodError) GetError() isPodErrors_PodError_Error

func (*PodErrors_PodError) ProtoMessage 

func (*PodErrors_PodError) ProtoMessage()

func (*PodErrors_PodError) Reset 

func (m *PodErrors_PodError) Reset()

func (*PodErrors_PodError) String 

func (m *PodErrors_PodError) String() string

func (*PodErrors_PodError) XXX_OneofFuncs 

func (*PodErrors_PodError) 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 PodErrors_PodError_Container 

type PodErrors_PodError_Container struct {
	Container *PodErrors_PodError_ContainerError `protobuf:"bytes,1,opt,name=container,oneof"`
}

type PodErrors_PodError_ContainerError 

type PodErrors_PodError_ContainerError struct {
	Message   string `protobuf:"bytes,1,opt,name=message" json:"message,omitempty"`
	Container string `protobuf:"bytes,2,opt,name=container" json:"container,omitempty"`
	Image     string `protobuf:"bytes,3,opt,name=image" json:"image,omitempty"`
	Reason    string `protobuf:"bytes,4,opt,name=reason" json:"reason,omitempty"`
}

To report init-container and container failures

func (*PodErrors_PodError_ContainerError) Descriptor 

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

func (*PodErrors_PodError_ContainerError) GetContainer 

func (m *PodErrors_PodError_ContainerError) GetContainer() string

func (*PodErrors_PodError_ContainerError) GetImage 

func (m *PodErrors_PodError_ContainerError) GetImage() string

func (*PodErrors_PodError_ContainerError) GetMessage 

func (m *PodErrors_PodError_ContainerError) GetMessage() string

func (*PodErrors_PodError_ContainerError) GetReason 

func (m *PodErrors_PodError_ContainerError) GetReason() string

func (*PodErrors_PodError_ContainerError) ProtoMessage 

func (*PodErrors_PodError_ContainerError) ProtoMessage()

func (*PodErrors_PodError_ContainerError) Reset 

func (m *PodErrors_PodError_ContainerError) Reset()

func (*PodErrors_PodError_ContainerError) String 

func (m *PodErrors_PodError_ContainerError) String() string

type Resource 

type Resource struct {
	// The namespace the resource is in.
	//
	// If empty, indicates all namespaces should be considered.
	Namespace string `protobuf:"bytes,1,opt,name=namespace" json:"namespace,omitempty"`
	// The type of resource.
	//
	// This can be:
	// - "all" -- includes all Kubernetes resource types only
	// - "authority" -- a special resource type derived from request `:authority` values
	// - Otherwise, the resource type may be any Kubernetes resource (e.g. "namespace", "deployment").
	Type string `protobuf:"bytes,2,opt,name=type" json:"type,omitempty"`
	// An optional resource name.
	Name string `protobuf:"bytes,3,opt,name=name" json:"name,omitempty"`
}

func (*Resource) Descriptor 

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

func (*Resource) GetName 

func (m *Resource) GetName() string

func (*Resource) GetNamespace 

func (m *Resource) GetNamespace() string

func (*Resource) GetType 

func (m *Resource) GetType() string

func (*Resource) ProtoMessage 

func (*Resource) ProtoMessage()

func (*Resource) Reset 

func (m *Resource) Reset()

func (*Resource) String 

func (m *Resource) String() string

type ResourceError 

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 

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

func (*ResourceError) GetError 

func (m *ResourceError) GetError() string

func (*ResourceError) GetResource 

func (m *ResourceError) GetResource() *Resource

func (*ResourceError) ProtoMessage 

func (*ResourceError) ProtoMessage()

func (*ResourceError) Reset 

func (m *ResourceError) Reset()

func (*ResourceError) String 

func (m *ResourceError) String() string

type ResourceSelection 

type ResourceSelection struct {
	// Identifies a Kubernetes resource.
	Resource *Resource `protobuf:"bytes,1,opt,name=resource" json:"resource,omitempty"`
	// A string-formatted Kubernetes label selector as passed to `kubectl get
	// --selector`.
	//
	// XXX in the future this may be superceded by a data structure that more
	// richly describes a parsed label selector.
	LabelSelector string `protobuf:"bytes,2,opt,name=label_selector,json=labelSelector" json:"label_selector,omitempty"`
}

func (*ResourceSelection) Descriptor 

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

func (*ResourceSelection) GetLabelSelector 

func (m *ResourceSelection) GetLabelSelector() string

func (*ResourceSelection) GetResource 

func (m *ResourceSelection) GetResource() *Resource

func (*ResourceSelection) ProtoMessage 

func (*ResourceSelection) ProtoMessage()

func (*ResourceSelection) Reset 

func (m *ResourceSelection) Reset()

func (*ResourceSelection) String 

func (m *ResourceSelection) String() string

type StatSummaryRequest 

type StatSummaryRequest struct {
	Selector   *ResourceSelection `protobuf:"bytes,1,opt,name=selector" json:"selector,omitempty"`
	TimeWindow string             `protobuf:"bytes,2,opt,name=time_window,json=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 

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

func (*StatSummaryRequest) GetFromResource 

func (m *StatSummaryRequest) GetFromResource() *Resource

func (*StatSummaryRequest) GetNone 

func (m *StatSummaryRequest) GetNone() *Empty

func (*StatSummaryRequest) GetOutbound 

func (m *StatSummaryRequest) GetOutbound() isStatSummaryRequest_Outbound

func (*StatSummaryRequest) GetSelector 

func (m *StatSummaryRequest) GetSelector() *ResourceSelection

func (*StatSummaryRequest) GetTimeWindow 

func (m *StatSummaryRequest) GetTimeWindow() string

func (*StatSummaryRequest) GetToResource 

func (m *StatSummaryRequest) GetToResource() *Resource

func (*StatSummaryRequest) ProtoMessage 

func (*StatSummaryRequest) ProtoMessage()

func (*StatSummaryRequest) Reset 

func (m *StatSummaryRequest) Reset()

func (*StatSummaryRequest) String 

func (m *StatSummaryRequest) String() string

func (*StatSummaryRequest) XXX_OneofFuncs 

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 

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

type StatSummaryRequest_None 

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

type StatSummaryRequest_ToResource 

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

type StatSummaryResponse 

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 

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

func (*StatSummaryResponse) GetError 

func (m *StatSummaryResponse) GetError() *ResourceError

func (*StatSummaryResponse) GetOk 

func (m *StatSummaryResponse) GetOk() *StatSummaryResponse_Ok

func (*StatSummaryResponse) GetResponse 

func (m *StatSummaryResponse) GetResponse() isStatSummaryResponse_Response

func (*StatSummaryResponse) ProtoMessage 

func (*StatSummaryResponse) ProtoMessage()

func (*StatSummaryResponse) Reset 

func (m *StatSummaryResponse) Reset()

func (*StatSummaryResponse) String 

func (m *StatSummaryResponse) String() string

func (*StatSummaryResponse) XXX_OneofFuncs 

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 

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

type StatSummaryResponse_Ok 

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

func (*StatSummaryResponse_Ok) Descriptor 

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

func (*StatSummaryResponse_Ok) GetStatTables 

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

func (*StatSummaryResponse_Ok) ProtoMessage 

func (*StatSummaryResponse_Ok) ProtoMessage()

func (*StatSummaryResponse_Ok) Reset 

func (m *StatSummaryResponse_Ok) Reset()

func (*StatSummaryResponse_Ok) String 

func (m *StatSummaryResponse_Ok) String() string

type StatSummaryResponse_Ok_ 

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

type StatTable 

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

func (*StatTable) Descriptor 

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

func (*StatTable) GetPodGroup 

func (m *StatTable) GetPodGroup() *StatTable_PodGroup

func (*StatTable) GetTable 

func (m *StatTable) GetTable() isStatTable_Table

func (*StatTable) ProtoMessage 

func (*StatTable) ProtoMessage()

func (*StatTable) Reset 

func (m *StatTable) Reset()

func (*StatTable) String 

func (m *StatTable) String() string

func (*StatTable) XXX_OneofFuncs 

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 

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

func (*StatTable_PodGroup) Descriptor 

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

func (*StatTable_PodGroup) GetRows 

func (m *StatTable_PodGroup) GetRows() []*StatTable_PodGroup_Row

func (*StatTable_PodGroup) ProtoMessage 

func (*StatTable_PodGroup) ProtoMessage()

func (*StatTable_PodGroup) Reset 

func (m *StatTable_PodGroup) Reset()

func (*StatTable_PodGroup) String 

func (m *StatTable_PodGroup) String() string

type StatTable_PodGroup_ 

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

type StatTable_PodGroup_Row 

type StatTable_PodGroup_Row struct {
	Resource   *Resource `protobuf:"bytes,1,opt,name=resource" json:"resource,omitempty"`
	TimeWindow string    `protobuf:"bytes,2,opt,name=time_window,json=timeWindow" json:"time_window,omitempty"`
	// number of pending or running pods in this resource that have conduit injected
	MeshedPodCount uint64 `protobuf:"varint,3,opt,name=meshed_pod_count,json=meshedPodCount" json:"meshed_pod_count,omitempty"`
	// number of pending or running pods in this resource
	RunningPodCount uint64 `protobuf:"varint,4,opt,name=running_pod_count,json=runningPodCount" json:"running_pod_count,omitempty"`
	// number of pods in this resource that have Phase PodFailed
	FailedPodCount uint64      `protobuf:"varint,6,opt,name=failed_pod_count,json=failedPodCount" json:"failed_pod_count,omitempty"`
	Stats          *BasicStats `protobuf:"bytes,5,opt,name=stats" json:"stats,omitempty"`
	// Stores a set of errors for each pod name. If a pod has no errors, it may be omitted.
	ErrorsByPod map[string]*PodErrors `` /* 163-byte string literal not displayed */
}

func (*StatTable_PodGroup_Row) Descriptor 

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

func (*StatTable_PodGroup_Row) GetErrorsByPod 

func (m *StatTable_PodGroup_Row) GetErrorsByPod() map[string]*PodErrors

func (*StatTable_PodGroup_Row) GetFailedPodCount 

func (m *StatTable_PodGroup_Row) GetFailedPodCount() uint64

func (*StatTable_PodGroup_Row) GetMeshedPodCount 

func (m *StatTable_PodGroup_Row) GetMeshedPodCount() uint64

func (*StatTable_PodGroup_Row) GetResource 

func (m *StatTable_PodGroup_Row) GetResource() *Resource

func (*StatTable_PodGroup_Row) GetRunningPodCount 

func (m *StatTable_PodGroup_Row) GetRunningPodCount() uint64

func (*StatTable_PodGroup_Row) GetStats 

func (m *StatTable_PodGroup_Row) GetStats() *BasicStats

func (*StatTable_PodGroup_Row) GetTimeWindow 

func (m *StatTable_PodGroup_Row) GetTimeWindow() string

func (*StatTable_PodGroup_Row) ProtoMessage 

func (*StatTable_PodGroup_Row) ProtoMessage()

func (*StatTable_PodGroup_Row) Reset 

func (m *StatTable_PodGroup_Row) Reset()

func (*StatTable_PodGroup_Row) String 

func (m *StatTable_PodGroup_Row) String() string

type TapByResourceRequest 

type TapByResourceRequest struct {
	// Describes the kubernetes pods that should be tapped.
	Target *ResourceSelection `protobuf:"bytes,1,opt,name=target" json:"target,omitempty"`
	// Selects over events to be reported.
	Match *TapByResourceRequest_Match `protobuf:"bytes,2,opt,name=match" json:"match,omitempty"`
	// Limits the number of events to be inspected.
	MaxRps float32 `protobuf:"fixed32,3,opt,name=maxRps" json:"maxRps,omitempty"`
}

A tap request over kubernetes resources.

func (*TapByResourceRequest) Descriptor 

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

func (*TapByResourceRequest) GetMatch 

func (m *TapByResourceRequest) GetMatch() *TapByResourceRequest_Match

func (*TapByResourceRequest) GetMaxRps 

func (m *TapByResourceRequest) GetMaxRps() float32

func (*TapByResourceRequest) GetTarget 

func (m *TapByResourceRequest) GetTarget() *ResourceSelection

func (*TapByResourceRequest) ProtoMessage 

func (*TapByResourceRequest) ProtoMessage()

func (*TapByResourceRequest) Reset 

func (m *TapByResourceRequest) Reset()

func (*TapByResourceRequest) String 

func (m *TapByResourceRequest) String() string

type TapByResourceRequest_Match 

type TapByResourceRequest_Match struct {
	// Types that are valid to be assigned to Match:
	//	*TapByResourceRequest_Match_All
	//	*TapByResourceRequest_Match_Any
	//	*TapByResourceRequest_Match_Not
	//	*TapByResourceRequest_Match_Destinations
	//	*TapByResourceRequest_Match_Http_
	Match isTapByResourceRequest_Match_Match `protobuf_oneof:"match"`
}

func (*TapByResourceRequest_Match) Descriptor 

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

func (*TapByResourceRequest_Match) GetAll 

func (m *TapByResourceRequest_Match) GetAll() *TapByResourceRequest_Match_Seq

func (*TapByResourceRequest_Match) GetAny 

func (m *TapByResourceRequest_Match) GetAny() *TapByResourceRequest_Match_Seq

func (*TapByResourceRequest_Match) GetDestinations 

func (m *TapByResourceRequest_Match) GetDestinations() *ResourceSelection

func (*TapByResourceRequest_Match) GetHttp 

func (m *TapByResourceRequest_Match) GetHttp() *TapByResourceRequest_Match_Http

func (*TapByResourceRequest_Match) GetMatch 

func (m *TapByResourceRequest_Match) GetMatch() isTapByResourceRequest_Match_Match

func (*TapByResourceRequest_Match) GetNot 

func (m *TapByResourceRequest_Match) GetNot() *TapByResourceRequest_Match

func (*TapByResourceRequest_Match) ProtoMessage 

func (*TapByResourceRequest_Match) ProtoMessage()

func (*TapByResourceRequest_Match) Reset 

func (m *TapByResourceRequest_Match) Reset()

func (*TapByResourceRequest_Match) String 

func (m *TapByResourceRequest_Match) String() string

func (*TapByResourceRequest_Match) XXX_OneofFuncs 

func (*TapByResourceRequest_Match) 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 TapByResourceRequest_Match_All 

type TapByResourceRequest_Match_All struct {
	All *TapByResourceRequest_Match_Seq `protobuf:"bytes,1,opt,name=all,oneof"`
}

type TapByResourceRequest_Match_Any 

type TapByResourceRequest_Match_Any struct {
	Any *TapByResourceRequest_Match_Seq `protobuf:"bytes,2,opt,name=any,oneof"`
}

type TapByResourceRequest_Match_Destinations 

type TapByResourceRequest_Match_Destinations struct {
	Destinations *ResourceSelection `protobuf:"bytes,4,opt,name=destinations,oneof"`
}

type TapByResourceRequest_Match_Http 

type TapByResourceRequest_Match_Http struct {
	// Types that are valid to be assigned to Match:
	//	*TapByResourceRequest_Match_Http_Scheme
	//	*TapByResourceRequest_Match_Http_Method
	//	*TapByResourceRequest_Match_Http_Authority
	//	*TapByResourceRequest_Match_Http_Path
	Match isTapByResourceRequest_Match_Http_Match `protobuf_oneof:"match"`
}

func (*TapByResourceRequest_Match_Http) Descriptor 

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

func (*TapByResourceRequest_Match_Http) GetAuthority 

func (m *TapByResourceRequest_Match_Http) GetAuthority() string

func (*TapByResourceRequest_Match_Http) GetMatch 

func (m *TapByResourceRequest_Match_Http) GetMatch() isTapByResourceRequest_Match_Http_Match

func (*TapByResourceRequest_Match_Http) GetMethod 

func (m *TapByResourceRequest_Match_Http) GetMethod() string

func (*TapByResourceRequest_Match_Http) GetPath 

func (m *TapByResourceRequest_Match_Http) GetPath() string

func (*TapByResourceRequest_Match_Http) GetScheme 

func (m *TapByResourceRequest_Match_Http) GetScheme() string

func (*TapByResourceRequest_Match_Http) ProtoMessage 

func (*TapByResourceRequest_Match_Http) ProtoMessage()

func (*TapByResourceRequest_Match_Http) Reset 

func (m *TapByResourceRequest_Match_Http) Reset()

func (*TapByResourceRequest_Match_Http) String 

func (m *TapByResourceRequest_Match_Http) String() string

func (*TapByResourceRequest_Match_Http) XXX_OneofFuncs 

func (*TapByResourceRequest_Match_Http) 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 TapByResourceRequest_Match_Http_ 

type TapByResourceRequest_Match_Http_ struct {
	Http *TapByResourceRequest_Match_Http `protobuf:"bytes,5,opt,name=http,oneof"`
}

type TapByResourceRequest_Match_Http_Authority 

type TapByResourceRequest_Match_Http_Authority struct {
	Authority string `protobuf:"bytes,3,opt,name=authority,oneof"`
}

type TapByResourceRequest_Match_Http_Method 

type TapByResourceRequest_Match_Http_Method struct {
	Method string `protobuf:"bytes,2,opt,name=method,oneof"`
}

type TapByResourceRequest_Match_Http_Path 

type TapByResourceRequest_Match_Http_Path struct {
	Path string `protobuf:"bytes,4,opt,name=path,oneof"`
}

type TapByResourceRequest_Match_Http_Scheme 

type TapByResourceRequest_Match_Http_Scheme struct {
	Scheme string `protobuf:"bytes,1,opt,name=scheme,oneof"`
}

type TapByResourceRequest_Match_Not 

type TapByResourceRequest_Match_Not struct {
	Not *TapByResourceRequest_Match `protobuf:"bytes,3,opt,name=not,oneof"`
}

type TapByResourceRequest_Match_Seq 

type TapByResourceRequest_Match_Seq struct {
	Matches []*TapByResourceRequest_Match `protobuf:"bytes,1,rep,name=matches" json:"matches,omitempty"`
}

func (*TapByResourceRequest_Match_Seq) Descriptor 

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

func (*TapByResourceRequest_Match_Seq) GetMatches 

func (m *TapByResourceRequest_Match_Seq) GetMatches() []*TapByResourceRequest_Match

func (*TapByResourceRequest_Match_Seq) ProtoMessage 

func (*TapByResourceRequest_Match_Seq) ProtoMessage()

func (*TapByResourceRequest_Match_Seq) Reset 

func (m *TapByResourceRequest_Match_Seq) Reset()

func (*TapByResourceRequest_Match_Seq) String 

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