conduit_public

package
v0.4.3 Latest Latest
Warning

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

 Go to latest Published: Jun 11, 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
TapByResourceRequest
ApiError
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 *Empty, 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 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 {
	StatSummary(context.Context, *StatSummaryRequest) (*StatSummaryResponse, error)
	ListPods(context.Context, *Empty) (*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 added in v0.4.1 

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

type Api_TapByResourceServer added in v0.4.1 

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 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"`
	TlsRequestCount uint64 `protobuf:"varint,6,opt,name=tls_request_count,json=tlsRequestCount" json:"tls_request_count,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) GetTlsRequestCount added in v0.4.2 

func (m *BasicStats) GetTlsRequestCount() 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 {
	// 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 Kubernetes resource.
	//
	// E.g. pod, deployment, service, ...
	//
	// If `all` refers, to all resource types.
	Type string `protobuf:"bytes,2,opt,name=type" json:"type,omitempty"`
	// An optional Kubernetes resource name.
	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 {
	// 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 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 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 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() string

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 (m *StatSummaryResponse) GetOk() *StatSummaryResponse_Ok

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 (m *StatTable_PodGroup) GetRows() []*StatTable_PodGroup_Row

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 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"`
}

func (*StatTable_PodGroup_Row) Descriptor added in v0.4.0 

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

func (*StatTable_PodGroup_Row) GetFailedPodCount added in v0.4.2 

func (m *StatTable_PodGroup_Row) GetFailedPodCount() uint64

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) GetRunningPodCount added in v0.4.2 

func (m *StatTable_PodGroup_Row) GetRunningPodCount() uint64

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() string

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 TapByResourceRequest added in v0.4.1 

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

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

func (*TapByResourceRequest) GetMatch added in v0.4.1 

func (m *TapByResourceRequest) GetMatch() *TapByResourceRequest_Match

func (*TapByResourceRequest) GetMaxRps added in v0.4.1 

func (m *TapByResourceRequest) GetMaxRps() float32

func (*TapByResourceRequest) GetTarget added in v0.4.1 

func (m *TapByResourceRequest) GetTarget() *ResourceSelection

func (*TapByResourceRequest) ProtoMessage added in v0.4.1 

func (*TapByResourceRequest) ProtoMessage()

func (*TapByResourceRequest) Reset added in v0.4.1 

func (m *TapByResourceRequest) Reset()

func (*TapByResourceRequest) String added in v0.4.1 

func (m *TapByResourceRequest) String() string

type TapByResourceRequest_Match added in v0.4.1 

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

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

func (*TapByResourceRequest_Match) GetAll added in v0.4.1 

func (m *TapByResourceRequest_Match) GetAll() *TapByResourceRequest_Match_Seq

func (*TapByResourceRequest_Match) GetAny added in v0.4.1 

func (m *TapByResourceRequest_Match) GetAny() *TapByResourceRequest_Match_Seq

func (*TapByResourceRequest_Match) GetDestinations added in v0.4.1 

func (m *TapByResourceRequest_Match) GetDestinations() *ResourceSelection

func (*TapByResourceRequest_Match) GetHttp added in v0.4.1 

func (m *TapByResourceRequest_Match) GetHttp() *TapByResourceRequest_Match_Http

func (*TapByResourceRequest_Match) GetMatch added in v0.4.1 

func (m *TapByResourceRequest_Match) GetMatch() isTapByResourceRequest_Match_Match

func (*TapByResourceRequest_Match) GetNot added in v0.4.1 

func (m *TapByResourceRequest_Match) GetNot() *TapByResourceRequest_Match

func (*TapByResourceRequest_Match) ProtoMessage added in v0.4.1 

func (*TapByResourceRequest_Match) ProtoMessage()

func (*TapByResourceRequest_Match) Reset added in v0.4.1 

func (m *TapByResourceRequest_Match) Reset()

func (*TapByResourceRequest_Match) String added in v0.4.1 

func (m *TapByResourceRequest_Match) String() string

func (*TapByResourceRequest_Match) XXX_OneofFuncs added in v0.4.1 

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

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

type TapByResourceRequest_Match_Any added in v0.4.1 

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

type TapByResourceRequest_Match_Destinations added in v0.4.1 

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

type TapByResourceRequest_Match_Http added in v0.4.1 

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

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

func (*TapByResourceRequest_Match_Http) GetAuthority added in v0.4.1 

func (m *TapByResourceRequest_Match_Http) GetAuthority() string

func (*TapByResourceRequest_Match_Http) GetMatch added in v0.4.1 

func (m *TapByResourceRequest_Match_Http) GetMatch() isTapByResourceRequest_Match_Http_Match

func (*TapByResourceRequest_Match_Http) GetMethod added in v0.4.1 

func (m *TapByResourceRequest_Match_Http) GetMethod() string

func (*TapByResourceRequest_Match_Http) GetPath added in v0.4.1 

func (m *TapByResourceRequest_Match_Http) GetPath() string

func (*TapByResourceRequest_Match_Http) GetScheme added in v0.4.1 

func (m *TapByResourceRequest_Match_Http) GetScheme() string

func (*TapByResourceRequest_Match_Http) ProtoMessage added in v0.4.1 

func (*TapByResourceRequest_Match_Http) ProtoMessage()

func (*TapByResourceRequest_Match_Http) Reset added in v0.4.1 

func (m *TapByResourceRequest_Match_Http) Reset()

func (*TapByResourceRequest_Match_Http) String added in v0.4.1 

func (m *TapByResourceRequest_Match_Http) String() string

func (*TapByResourceRequest_Match_Http) XXX_OneofFuncs added in v0.4.1 

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_ added in v0.4.1 

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

type TapByResourceRequest_Match_Http_Authority added in v0.4.1 

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

type TapByResourceRequest_Match_Http_Method added in v0.4.1 

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

type TapByResourceRequest_Match_Http_Path added in v0.4.1 

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

type TapByResourceRequest_Match_Http_Scheme added in v0.4.1 

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

type TapByResourceRequest_Match_Not added in v0.4.1 

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

type TapByResourceRequest_Match_Seq added in v0.4.1 

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

func (*TapByResourceRequest_Match_Seq) Descriptor added in v0.4.1 

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

func (*TapByResourceRequest_Match_Seq) GetMatches added in v0.4.1 

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

func (*TapByResourceRequest_Match_Seq) ProtoMessage added in v0.4.1 

func (*TapByResourceRequest_Match_Seq) ProtoMessage()

func (*TapByResourceRequest_Match_Seq) Reset added in v0.4.1 

func (m *TapByResourceRequest_Match_Seq) Reset()

func (*TapByResourceRequest_Match_Seq) String added in v0.4.1 

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.