public

package
v18.7.3+incompatible Latest Latest
Warning

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

 Go to latest Published: Jul 31, 2018 License: Apache-2.0 Imports: 7 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
HttpMethod
Scheme
IPAddress
IPv6
TcpAddress
Eos
TapEvent
ApiError
PodErrors
Resource
ResourceSelection
ResourceError
StatSummaryRequest
StatSummaryResponse
BasicStats
StatTable

Index

Constants

This section is empty.

Variables

View Source 
var HttpMethod_Registered_name = map[int32]string{
	0: "GET",
	1: "POST",
	2: "PUT",
	3: "DELETE",
	4: "PATCH",
	5: "OPTIONS",
	6: "CONNECT",
	7: "HEAD",
	8: "TRACE",
}
View Source 
var HttpMethod_Registered_value = map[string]int32{
	"GET":     0,
	"POST":    1,
	"PUT":     2,
	"DELETE":  3,
	"PATCH":   4,
	"OPTIONS": 5,
	"CONNECT": 6,
	"HEAD":    7,
	"TRACE":   8,
}
View Source 
var Scheme_Registered_name = map[int32]string{
	0: "HTTP",
	1: "HTTPS",
}
View Source 
var Scheme_Registered_value = map[string]int32{
	"HTTP":  0,
	"HTTPS": 1,
}
View Source 
var TapEvent_ProxyDirection_name = map[int32]string{
	0: "UNKNOWN",
	1: "INBOUND",
	2: "OUTBOUND",
}
View Source 
var TapEvent_ProxyDirection_value = map[string]int32{
	"UNKNOWN":  0,
	"INBOUND":  1,
	"OUTBOUND": 2,
}

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 *linkerd2_common_healthcheck.SelfCheckRequest, opts ...grpc.CallOption) (*linkerd2_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, *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, *linkerd2_common_healthcheck.SelfCheckRequest) (*linkerd2_common_healthcheck.SelfCheckResponse, error)
}

type Api_TapByResourceClient added in v0.4.1 

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

type Api_TapByResourceServer added in v0.4.1 

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

type Api_TapClient 

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

type Api_TapServer 

type Api_TapServer interface {
	Send(*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 Eos 

type Eos struct {
	// Types that are valid to be assigned to End:
	//	*Eos_GrpcStatusCode
	//	*Eos_ResetErrorCode
	End isEos_End `protobuf_oneof:"end"`
}

func (*Eos) Descriptor 

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

func (*Eos) GetEnd 

func (m *Eos) GetEnd() isEos_End

func (*Eos) GetGrpcStatusCode 

func (m *Eos) GetGrpcStatusCode() uint32

func (*Eos) GetResetErrorCode 

func (m *Eos) GetResetErrorCode() uint32

func (*Eos) ProtoMessage 

func (*Eos) ProtoMessage()

func (*Eos) Reset 

func (m *Eos) Reset()

func (*Eos) String 

func (m *Eos) String() string

func (*Eos) XXX_OneofFuncs 

func (*Eos) 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 Eos_GrpcStatusCode 

type Eos_GrpcStatusCode struct {
	GrpcStatusCode uint32 `protobuf:"varint,1,opt,name=grpc_status_code,json=grpcStatusCode,oneof"`
}

type Eos_ResetErrorCode 

type Eos_ResetErrorCode struct {
	ResetErrorCode uint32 `protobuf:"varint,2,opt,name=reset_error_code,json=resetErrorCode,oneof"`
}

type HttpMethod 

type HttpMethod struct {
	// Types that are valid to be assigned to Type:
	//	*HttpMethod_Registered_
	//	*HttpMethod_Unregistered
	Type isHttpMethod_Type `protobuf_oneof:"type"`
}

func (*HttpMethod) Descriptor 

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

func (*HttpMethod) GetRegistered 

func (m *HttpMethod) GetRegistered() HttpMethod_Registered

func (*HttpMethod) GetType 

func (m *HttpMethod) GetType() isHttpMethod_Type

func (*HttpMethod) GetUnregistered 

func (m *HttpMethod) GetUnregistered() string

func (*HttpMethod) ProtoMessage 

func (*HttpMethod) ProtoMessage()

func (*HttpMethod) Reset 

func (m *HttpMethod) Reset()

func (*HttpMethod) String 

func (m *HttpMethod) String() string

func (*HttpMethod) XXX_OneofFuncs 

func (*HttpMethod) 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 HttpMethod_Registered 

type HttpMethod_Registered int32
const (
	HttpMethod_GET     HttpMethod_Registered = 0
	HttpMethod_POST    HttpMethod_Registered = 1
	HttpMethod_PUT     HttpMethod_Registered = 2
	HttpMethod_DELETE  HttpMethod_Registered = 3
	HttpMethod_PATCH   HttpMethod_Registered = 4
	HttpMethod_OPTIONS HttpMethod_Registered = 5
	HttpMethod_CONNECT HttpMethod_Registered = 6
	HttpMethod_HEAD    HttpMethod_Registered = 7
	HttpMethod_TRACE   HttpMethod_Registered = 8
)

func (HttpMethod_Registered) EnumDescriptor 

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

func (HttpMethod_Registered) String 

func (x HttpMethod_Registered) String() string

type HttpMethod_Registered_ 

type HttpMethod_Registered_ struct {
	Registered HttpMethod_Registered `protobuf:"varint,1,opt,name=registered,enum=linkerd2.public.HttpMethod_Registered,oneof"`
}

type HttpMethod_Unregistered 

type HttpMethod_Unregistered struct {
	Unregistered string `protobuf:"bytes,2,opt,name=unregistered,oneof"`
}

type IPAddress 

type IPAddress struct {
	// Types that are valid to be assigned to Ip:
	//	*IPAddress_Ipv4
	//	*IPAddress_Ipv6
	Ip isIPAddress_Ip `protobuf_oneof:"ip"`
}

func (*IPAddress) Descriptor 

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

func (*IPAddress) GetIp 

func (m *IPAddress) GetIp() isIPAddress_Ip

func (*IPAddress) GetIpv4 

func (m *IPAddress) GetIpv4() uint32

func (*IPAddress) GetIpv6 

func (m *IPAddress) GetIpv6() *IPv6

func (*IPAddress) ProtoMessage 

func (*IPAddress) ProtoMessage()

func (*IPAddress) Reset 

func (m *IPAddress) Reset()

func (*IPAddress) String 

func (m *IPAddress) String() string

func (*IPAddress) XXX_OneofFuncs 

func (*IPAddress) 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 IPAddress_Ipv4 

type IPAddress_Ipv4 struct {
	Ipv4 uint32 `protobuf:"fixed32,1,opt,name=ipv4,oneof"`
}

type IPAddress_Ipv6 

type IPAddress_Ipv6 struct {
	Ipv6 *IPv6 `protobuf:"bytes,2,opt,name=ipv6,oneof"`
}

type IPv6 

type IPv6 struct {
	First uint64 `protobuf:"fixed64,1,opt,name=first" json:"first,omitempty"`
	Last  uint64 `protobuf:"fixed64,2,opt,name=last" json:"last,omitempty"`
}

func (*IPv6) Descriptor 

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

func (*IPv6) GetFirst 

func (m *IPv6) GetFirst() uint64

func (*IPv6) GetLast 

func (m *IPv6) GetLast() uint64

func (*IPv6) ProtoMessage 

func (*IPv6) ProtoMessage()

func (*IPv6) Reset 

func (m *IPv6) Reset()

func (*IPv6) String 

func (m *IPv6) String() string

type ListPodsRequest added in v0.5.0 

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

func (*ListPodsRequest) Descriptor added in v0.5.0 

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

func (*ListPodsRequest) GetNamespace added in v0.5.0 

func (m *ListPodsRequest) GetNamespace() string

func (*ListPodsRequest) ProtoMessage added in v0.5.0 

func (*ListPodsRequest) ProtoMessage()

func (*ListPodsRequest) Reset added in v0.5.0 

func (m *ListPodsRequest) Reset()

func (*ListPodsRequest) String added in v0.5.0 

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"`
	// Types that are valid to be assigned to Owner:
	//	*Pod_Deployment
	//	*Pod_ReplicaSet
	//	*Pod_ReplicationController
	//	*Pod_StatefulSet
	//	*Pod_DaemonSet
	//	*Pod_Job
	Owner               isPod_Owner               `protobuf_oneof:"owner"`
	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) GetDaemonSet 

func (m *Pod) GetDaemonSet() string

func (*Pod) GetDeployment 

func (m *Pod) GetDeployment() string

func (*Pod) GetJob 

func (m *Pod) GetJob() string

func (*Pod) GetName 

func (m *Pod) GetName() string

func (*Pod) GetOwner 

func (m *Pod) GetOwner() isPod_Owner

func (*Pod) GetPodIP 

func (m *Pod) GetPodIP() string

func (*Pod) GetReplicaSet 

func (m *Pod) GetReplicaSet() string

func (*Pod) GetReplicationController 

func (m *Pod) GetReplicationController() string

func (*Pod) GetSinceLastReport 

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

func (*Pod) GetStatefulSet 

func (m *Pod) GetStatefulSet() string

func (*Pod) GetStatus 

func (m *Pod) GetStatus() string

func (*Pod) GetUptime added in v0.5.0 

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

func (*Pod) XXX_OneofFuncs 

func (*Pod) 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 added in v0.4.4 

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

func (*PodErrors) Descriptor added in v0.4.4 

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

func (*PodErrors) GetErrors added in v0.4.4 

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

func (*PodErrors) ProtoMessage added in v0.4.4 

func (*PodErrors) ProtoMessage()

func (*PodErrors) Reset added in v0.4.4 

func (m *PodErrors) Reset()

func (*PodErrors) String added in v0.4.4 

func (m *PodErrors) String() string

type PodErrors_PodError added in v0.4.4 

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

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

func (*PodErrors_PodError) GetContainer added in v0.4.4 

func (m *PodErrors_PodError) GetContainer() *PodErrors_PodError_ContainerError

func (*PodErrors_PodError) GetError added in v0.4.4 

func (m *PodErrors_PodError) GetError() isPodErrors_PodError_Error

func (*PodErrors_PodError) ProtoMessage added in v0.4.4 

func (*PodErrors_PodError) ProtoMessage()

func (*PodErrors_PodError) Reset added in v0.4.4 

func (m *PodErrors_PodError) Reset()

func (*PodErrors_PodError) String added in v0.4.4 

func (m *PodErrors_PodError) String() string

func (*PodErrors_PodError) XXX_OneofFuncs added in v0.4.4 

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

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

type PodErrors_PodError_ContainerError added in v0.4.4 

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

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

func (*PodErrors_PodError_ContainerError) GetContainer added in v0.4.4 

func (m *PodErrors_PodError_ContainerError) GetContainer() string

func (*PodErrors_PodError_ContainerError) GetImage added in v0.4.4 

func (m *PodErrors_PodError_ContainerError) GetImage() string

func (*PodErrors_PodError_ContainerError) GetMessage added in v0.4.4 

func (m *PodErrors_PodError_ContainerError) GetMessage() string

func (*PodErrors_PodError_ContainerError) GetReason added in v0.5.0 

func (m *PodErrors_PodError_ContainerError) GetReason() string

func (*PodErrors_PodError_ContainerError) ProtoMessage added in v0.4.4 

func (*PodErrors_PodError_ContainerError) ProtoMessage()

func (*PodErrors_PodError_ContainerError) Reset added in v0.4.4 

func (m *PodErrors_PodError_ContainerError) Reset()

func (*PodErrors_PodError_ContainerError) String added in v0.4.4 

func (m *PodErrors_PodError_ContainerError) String() string

type Pod_DaemonSet 

type Pod_DaemonSet struct {
	DaemonSet string `protobuf:"bytes,13,opt,name=daemon_set,json=daemonSet,oneof"`
}

type Pod_Deployment 

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

type Pod_Job 

type Pod_Job struct {
	Job string `protobuf:"bytes,14,opt,name=job,oneof"`
}

type Pod_ReplicaSet 

type Pod_ReplicaSet struct {
	ReplicaSet string `protobuf:"bytes,10,opt,name=replica_set,json=replicaSet,oneof"`
}

type Pod_ReplicationController 

type Pod_ReplicationController struct {
	ReplicationController string `protobuf:"bytes,11,opt,name=replication_controller,json=replicationController,oneof"`
}

type Pod_StatefulSet 

type Pod_StatefulSet struct {
	StatefulSet string `protobuf:"bytes,12,opt,name=stateful_set,json=statefulSet,oneof"`
}

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 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 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 Scheme 

type Scheme struct {
	// Types that are valid to be assigned to Type:
	//	*Scheme_Registered_
	//	*Scheme_Unregistered
	Type isScheme_Type `protobuf_oneof:"type"`
}

func (*Scheme) Descriptor 

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

func (*Scheme) GetRegistered 

func (m *Scheme) GetRegistered() Scheme_Registered

func (*Scheme) GetType 

func (m *Scheme) GetType() isScheme_Type

func (*Scheme) GetUnregistered 

func (m *Scheme) GetUnregistered() string

func (*Scheme) ProtoMessage 

func (*Scheme) ProtoMessage()

func (*Scheme) Reset 

func (m *Scheme) Reset()

func (*Scheme) String 

func (m *Scheme) String() string

func (*Scheme) XXX_OneofFuncs 

func (*Scheme) 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 Scheme_Registered 

type Scheme_Registered int32
const (
	Scheme_HTTP  Scheme_Registered = 0
	Scheme_HTTPS Scheme_Registered = 1
)

func (Scheme_Registered) EnumDescriptor 

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

func (Scheme_Registered) String 

func (x Scheme_Registered) String() string

type Scheme_Registered_ 

type Scheme_Registered_ struct {
	Registered Scheme_Registered `protobuf:"varint,1,opt,name=registered,enum=linkerd2.public.Scheme_Registered,oneof"`
}

type Scheme_Unregistered 

type Scheme_Unregistered struct {
	Unregistered string `protobuf:"bytes,2,opt,name=unregistered,oneof"`
}

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

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

func (*StatTable_PodGroup_Row) GetErrorsByPod added in v0.4.4 

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

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 TapEvent 

type TapEvent struct {
	Source          *TcpAddress             `protobuf:"bytes,1,opt,name=source" json:"source,omitempty"`
	SourceMeta      *TapEvent_EndpointMeta  `protobuf:"bytes,5,opt,name=source_meta,json=sourceMeta" json:"source_meta,omitempty"`
	Destination     *TcpAddress             `protobuf:"bytes,2,opt,name=destination" json:"destination,omitempty"`
	DestinationMeta *TapEvent_EndpointMeta  `protobuf:"bytes,4,opt,name=destination_meta,json=destinationMeta" json:"destination_meta,omitempty"`
	ProxyDirection  TapEvent_ProxyDirection `` /* 142-byte string literal not displayed */
	// Types that are valid to be assigned to Event:
	//	*TapEvent_Http_
	Event isTapEvent_Event `protobuf_oneof:"event"`
}

func (*TapEvent) Descriptor 

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

func (*TapEvent) GetDestination 

func (m *TapEvent) GetDestination() *TcpAddress

func (*TapEvent) GetDestinationMeta 

func (m *TapEvent) GetDestinationMeta() *TapEvent_EndpointMeta

func (*TapEvent) GetEvent 

func (m *TapEvent) GetEvent() isTapEvent_Event

func (*TapEvent) GetHttp 

func (m *TapEvent) GetHttp() *TapEvent_Http

func (*TapEvent) GetProxyDirection 

func (m *TapEvent) GetProxyDirection() TapEvent_ProxyDirection

func (*TapEvent) GetSource 

func (m *TapEvent) GetSource() *TcpAddress

func (*TapEvent) GetSourceMeta 

func (m *TapEvent) GetSourceMeta() *TapEvent_EndpointMeta

func (*TapEvent) ProtoMessage 

func (*TapEvent) ProtoMessage()

func (*TapEvent) Reset 

func (m *TapEvent) Reset()

func (*TapEvent) String 

func (m *TapEvent) String() string

func (*TapEvent) XXX_OneofFuncs 

func (*TapEvent) 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 TapEvent_EndpointMeta 

type TapEvent_EndpointMeta struct {
	Labels map[string]string `` /* 132-byte string literal not displayed */
}

func (*TapEvent_EndpointMeta) Descriptor 

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

func (*TapEvent_EndpointMeta) GetLabels 

func (m *TapEvent_EndpointMeta) GetLabels() map[string]string

func (*TapEvent_EndpointMeta) ProtoMessage 

func (*TapEvent_EndpointMeta) ProtoMessage()

func (*TapEvent_EndpointMeta) Reset 

func (m *TapEvent_EndpointMeta) Reset()

func (*TapEvent_EndpointMeta) String 

func (m *TapEvent_EndpointMeta) String() string

type TapEvent_Http 

type TapEvent_Http struct {
	// Types that are valid to be assigned to Event:
	//	*TapEvent_Http_RequestInit_
	//	*TapEvent_Http_ResponseInit_
	//	*TapEvent_Http_ResponseEnd_
	Event isTapEvent_Http_Event `protobuf_oneof:"event"`
}

func (*TapEvent_Http) Descriptor 

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

func (*TapEvent_Http) GetEvent 

func (m *TapEvent_Http) GetEvent() isTapEvent_Http_Event

func (*TapEvent_Http) GetRequestInit 

func (m *TapEvent_Http) GetRequestInit() *TapEvent_Http_RequestInit

func (*TapEvent_Http) GetResponseEnd 

func (m *TapEvent_Http) GetResponseEnd() *TapEvent_Http_ResponseEnd

func (*TapEvent_Http) GetResponseInit 

func (m *TapEvent_Http) GetResponseInit() *TapEvent_Http_ResponseInit

func (*TapEvent_Http) ProtoMessage 

func (*TapEvent_Http) ProtoMessage()

func (*TapEvent_Http) Reset 

func (m *TapEvent_Http) Reset()

func (*TapEvent_Http) String 

func (m *TapEvent_Http) String() string

func (*TapEvent_Http) XXX_OneofFuncs 

func (*TapEvent_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 TapEvent_Http_ 

type TapEvent_Http_ struct {
	Http *TapEvent_Http `protobuf:"bytes,3,opt,name=http,oneof"`
}

type TapEvent_Http_RequestInit 

type TapEvent_Http_RequestInit struct {
	Id        *TapEvent_Http_StreamId `protobuf:"bytes,1,opt,name=id" json:"id,omitempty"`
	Method    *HttpMethod             `protobuf:"bytes,2,opt,name=method" json:"method,omitempty"`
	Scheme    *Scheme                 `protobuf:"bytes,3,opt,name=scheme" json:"scheme,omitempty"`
	Authority string                  `protobuf:"bytes,4,opt,name=authority" json:"authority,omitempty"`
	Path      string                  `protobuf:"bytes,5,opt,name=path" json:"path,omitempty"`
}

func (*TapEvent_Http_RequestInit) Descriptor 

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

func (*TapEvent_Http_RequestInit) GetAuthority 

func (m *TapEvent_Http_RequestInit) GetAuthority() string

func (*TapEvent_Http_RequestInit) GetId 

func (m *TapEvent_Http_RequestInit) GetId() *TapEvent_Http_StreamId

func (*TapEvent_Http_RequestInit) GetMethod 

func (m *TapEvent_Http_RequestInit) GetMethod() *HttpMethod

func (*TapEvent_Http_RequestInit) GetPath 

func (m *TapEvent_Http_RequestInit) GetPath() string

func (*TapEvent_Http_RequestInit) GetScheme 

func (m *TapEvent_Http_RequestInit) GetScheme() *Scheme

func (*TapEvent_Http_RequestInit) ProtoMessage 

func (*TapEvent_Http_RequestInit) ProtoMessage()

func (*TapEvent_Http_RequestInit) Reset 

func (m *TapEvent_Http_RequestInit) Reset()

func (*TapEvent_Http_RequestInit) String 

func (m *TapEvent_Http_RequestInit) String() string

type TapEvent_Http_RequestInit_ 

type TapEvent_Http_RequestInit_ struct {
	RequestInit *TapEvent_Http_RequestInit `protobuf:"bytes,1,opt,name=request_init,json=requestInit,oneof"`
}

type TapEvent_Http_ResponseEnd 

type TapEvent_Http_ResponseEnd struct {
	Id                *TapEvent_Http_StreamId   `protobuf:"bytes,1,opt,name=id" json:"id,omitempty"`
	SinceRequestInit  *google_protobuf.Duration `protobuf:"bytes,2,opt,name=since_request_init,json=sinceRequestInit" json:"since_request_init,omitempty"`
	SinceResponseInit *google_protobuf.Duration `protobuf:"bytes,3,opt,name=since_response_init,json=sinceResponseInit" json:"since_response_init,omitempty"`
	ResponseBytes     uint64                    `protobuf:"varint,4,opt,name=response_bytes,json=responseBytes" json:"response_bytes,omitempty"`
	Eos               *Eos                      `protobuf:"bytes,5,opt,name=eos" json:"eos,omitempty"`
}

func (*TapEvent_Http_ResponseEnd) Descriptor 

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

func (*TapEvent_Http_ResponseEnd) GetEos 

func (m *TapEvent_Http_ResponseEnd) GetEos() *Eos

func (*TapEvent_Http_ResponseEnd) GetId 

func (m *TapEvent_Http_ResponseEnd) GetId() *TapEvent_Http_StreamId

func (*TapEvent_Http_ResponseEnd) GetResponseBytes 

func (m *TapEvent_Http_ResponseEnd) GetResponseBytes() uint64

func (*TapEvent_Http_ResponseEnd) GetSinceRequestInit 

func (m *TapEvent_Http_ResponseEnd) GetSinceRequestInit() *google_protobuf.Duration

func (*TapEvent_Http_ResponseEnd) GetSinceResponseInit 

func (m *TapEvent_Http_ResponseEnd) GetSinceResponseInit() *google_protobuf.Duration

func (*TapEvent_Http_ResponseEnd) ProtoMessage 

func (*TapEvent_Http_ResponseEnd) ProtoMessage()

func (*TapEvent_Http_ResponseEnd) Reset 

func (m *TapEvent_Http_ResponseEnd) Reset()

func (*TapEvent_Http_ResponseEnd) String 

func (m *TapEvent_Http_ResponseEnd) String() string

type TapEvent_Http_ResponseEnd_ 

type TapEvent_Http_ResponseEnd_ struct {
	ResponseEnd *TapEvent_Http_ResponseEnd `protobuf:"bytes,3,opt,name=response_end,json=responseEnd,oneof"`
}

type TapEvent_Http_ResponseInit 

type TapEvent_Http_ResponseInit struct {
	Id               *TapEvent_Http_StreamId   `protobuf:"bytes,1,opt,name=id" json:"id,omitempty"`
	SinceRequestInit *google_protobuf.Duration `protobuf:"bytes,2,opt,name=since_request_init,json=sinceRequestInit" json:"since_request_init,omitempty"`
	HttpStatus       uint32                    `protobuf:"varint,3,opt,name=http_status,json=httpStatus" json:"http_status,omitempty"`
}

func (*TapEvent_Http_ResponseInit) Descriptor 

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

func (*TapEvent_Http_ResponseInit) GetHttpStatus 

func (m *TapEvent_Http_ResponseInit) GetHttpStatus() uint32

func (*TapEvent_Http_ResponseInit) GetId 

func (m *TapEvent_Http_ResponseInit) GetId() *TapEvent_Http_StreamId

func (*TapEvent_Http_ResponseInit) GetSinceRequestInit 

func (m *TapEvent_Http_ResponseInit) GetSinceRequestInit() *google_protobuf.Duration

func (*TapEvent_Http_ResponseInit) ProtoMessage 

func (*TapEvent_Http_ResponseInit) ProtoMessage()

func (*TapEvent_Http_ResponseInit) Reset 

func (m *TapEvent_Http_ResponseInit) Reset()

func (*TapEvent_Http_ResponseInit) String 

func (m *TapEvent_Http_ResponseInit) String() string

type TapEvent_Http_ResponseInit_ 

type TapEvent_Http_ResponseInit_ struct {
	ResponseInit *TapEvent_Http_ResponseInit `protobuf:"bytes,2,opt,name=response_init,json=responseInit,oneof"`
}

type TapEvent_Http_StreamId 

type TapEvent_Http_StreamId struct {
	// A randomized base (stable across a process's runtime)
	Base uint32 `protobuf:"varint,1,opt,name=base" json:"base,omitempty"`
	// A stream id unique within the lifetime of `base`.
	Stream uint64 `protobuf:"varint,2,opt,name=stream" json:"stream,omitempty"`
}

func (*TapEvent_Http_StreamId) Descriptor 

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

func (*TapEvent_Http_StreamId) GetBase 

func (m *TapEvent_Http_StreamId) GetBase() uint32

func (*TapEvent_Http_StreamId) GetStream 

func (m *TapEvent_Http_StreamId) GetStream() uint64

func (*TapEvent_Http_StreamId) ProtoMessage 

func (*TapEvent_Http_StreamId) ProtoMessage()

func (*TapEvent_Http_StreamId) Reset 

func (m *TapEvent_Http_StreamId) Reset()

func (*TapEvent_Http_StreamId) String 

func (m *TapEvent_Http_StreamId) String() string

type TapEvent_ProxyDirection 

type TapEvent_ProxyDirection int32
const (
	TapEvent_UNKNOWN  TapEvent_ProxyDirection = 0
	TapEvent_INBOUND  TapEvent_ProxyDirection = 1
	TapEvent_OUTBOUND TapEvent_ProxyDirection = 2
)

func (TapEvent_ProxyDirection) EnumDescriptor 

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

func (TapEvent_ProxyDirection) String 

func (x TapEvent_ProxyDirection) 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 TcpAddress 

type TcpAddress struct {
	Ip   *IPAddress `protobuf:"bytes,1,opt,name=ip" json:"ip,omitempty"`
	Port uint32     `protobuf:"varint,2,opt,name=port" json:"port,omitempty"`
}

func (*TcpAddress) Descriptor 

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

func (*TcpAddress) GetIp 

func (m *TcpAddress) GetIp() *IPAddress

func (*TcpAddress) GetPort 

func (m *TcpAddress) GetPort() uint32

func (*TcpAddress) ProtoMessage 

func (*TcpAddress) ProtoMessage()

func (*TcpAddress) Reset 

func (m *TcpAddress) Reset()

func (*TcpAddress) String 

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