public

package
v18.9.1+incompatible Latest Latest
Warning

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

Go to latest
Published: Sep 12, 2018 License: Apache-2.0 Imports: 7 Imported by: 0

Documentation

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

ApiClient is the client API for Api service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewApiClient

func NewApiClient(cc *grpc.ClientConn) ApiClient

type ApiError

type ApiError struct {
	Error                string   `protobuf:"bytes,1,opt,name=error,proto3" json:"error,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

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

func (*ApiError) XXX_DiscardUnknown

func (m *ApiError) XXX_DiscardUnknown()

func (*ApiError) XXX_Marshal

func (m *ApiError) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ApiError) XXX_Merge

func (dst *ApiError) XXX_Merge(src proto.Message)

func (*ApiError) XXX_Size

func (m *ApiError) XXX_Size() int

func (*ApiError) XXX_Unmarshal

func (m *ApiError) XXX_Unmarshal(b []byte) error

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, *healthcheck.SelfCheckRequest) (*healthcheck.SelfCheckResponse, error)
}

ApiServer is the server API for Api service.

type Api_TapByResourceClient

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

type Api_TapByResourceServer

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

type BasicStats struct {
	SuccessCount         uint64   `protobuf:"varint,1,opt,name=success_count,json=successCount,proto3" json:"success_count,omitempty"`
	FailureCount         uint64   `protobuf:"varint,2,opt,name=failure_count,json=failureCount,proto3" json:"failure_count,omitempty"`
	LatencyMsP50         uint64   `protobuf:"varint,3,opt,name=latency_ms_p50,json=latencyMsP50,proto3" json:"latency_ms_p50,omitempty"`
	LatencyMsP95         uint64   `protobuf:"varint,4,opt,name=latency_ms_p95,json=latencyMsP95,proto3" json:"latency_ms_p95,omitempty"`
	LatencyMsP99         uint64   `protobuf:"varint,5,opt,name=latency_ms_p99,json=latencyMsP99,proto3" json:"latency_ms_p99,omitempty"`
	TlsRequestCount      uint64   `protobuf:"varint,6,opt,name=tls_request_count,json=tlsRequestCount,proto3" json:"tls_request_count,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

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

func (*BasicStats) XXX_DiscardUnknown

func (m *BasicStats) XXX_DiscardUnknown()

func (*BasicStats) XXX_Marshal

func (m *BasicStats) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*BasicStats) XXX_Merge

func (dst *BasicStats) XXX_Merge(src proto.Message)

func (*BasicStats) XXX_Size

func (m *BasicStats) XXX_Size() int

func (*BasicStats) XXX_Unmarshal

func (m *BasicStats) XXX_Unmarshal(b []byte) error

type Empty

type Empty struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

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

func (*Empty) XXX_DiscardUnknown

func (m *Empty) XXX_DiscardUnknown()

func (*Empty) XXX_Marshal

func (m *Empty) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Empty) XXX_Merge

func (dst *Empty) XXX_Merge(src proto.Message)

func (*Empty) XXX_Size

func (m *Empty) XXX_Size() int

func (*Empty) XXX_Unmarshal

func (m *Empty) XXX_Unmarshal(b []byte) error

type Eos

type Eos struct {
	// Types that are valid to be assigned to End:
	//	*Eos_GrpcStatusCode
	//	*Eos_ResetErrorCode
	End                  isEos_End `protobuf_oneof:"end"`
	XXX_NoUnkeyedLiteral struct{}  `json:"-"`
	XXX_unrecognized     []byte    `json:"-"`
	XXX_sizecache        int32     `json:"-"`
}

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_DiscardUnknown

func (m *Eos) XXX_DiscardUnknown()

func (*Eos) XXX_Marshal

func (m *Eos) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Eos) XXX_Merge

func (dst *Eos) XXX_Merge(src proto.Message)

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.

func (*Eos) XXX_Size

func (m *Eos) XXX_Size() int

func (*Eos) XXX_Unmarshal

func (m *Eos) XXX_Unmarshal(b []byte) error

type Eos_GrpcStatusCode

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

type Eos_ResetErrorCode

type Eos_ResetErrorCode struct {
	ResetErrorCode uint32 `protobuf:"varint,2,opt,name=reset_error_code,json=resetErrorCode,proto3,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"`
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

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_DiscardUnknown

func (m *HttpMethod) XXX_DiscardUnknown()

func (*HttpMethod) XXX_Marshal

func (m *HttpMethod) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*HttpMethod) XXX_Merge

func (dst *HttpMethod) XXX_Merge(src proto.Message)

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.

func (*HttpMethod) XXX_Size

func (m *HttpMethod) XXX_Size() int

func (*HttpMethod) XXX_Unmarshal

func (m *HttpMethod) XXX_Unmarshal(b []byte) error

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,proto3,enum=linkerd2.public.HttpMethod_Registered,oneof"`
}

type HttpMethod_Unregistered

type HttpMethod_Unregistered struct {
	Unregistered string `protobuf:"bytes,2,opt,name=unregistered,proto3,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"`
	XXX_NoUnkeyedLiteral struct{}       `json:"-"`
	XXX_unrecognized     []byte         `json:"-"`
	XXX_sizecache        int32          `json:"-"`
}

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_DiscardUnknown

func (m *IPAddress) XXX_DiscardUnknown()

func (*IPAddress) XXX_Marshal

func (m *IPAddress) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*IPAddress) XXX_Merge

func (dst *IPAddress) XXX_Merge(src proto.Message)

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.

func (*IPAddress) XXX_Size

func (m *IPAddress) XXX_Size() int

func (*IPAddress) XXX_Unmarshal

func (m *IPAddress) XXX_Unmarshal(b []byte) error

type IPAddress_Ipv4

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

type IPAddress_Ipv6

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

type IPv6

type IPv6 struct {
	First                uint64   `protobuf:"fixed64,1,opt,name=first,proto3" json:"first,omitempty"`
	Last                 uint64   `protobuf:"fixed64,2,opt,name=last,proto3" json:"last,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

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

func (*IPv6) XXX_DiscardUnknown

func (m *IPv6) XXX_DiscardUnknown()

func (*IPv6) XXX_Marshal

func (m *IPv6) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*IPv6) XXX_Merge

func (dst *IPv6) XXX_Merge(src proto.Message)

func (*IPv6) XXX_Size

func (m *IPv6) XXX_Size() int

func (*IPv6) XXX_Unmarshal

func (m *IPv6) XXX_Unmarshal(b []byte) error

type ListPodsRequest

type ListPodsRequest struct {
	Namespace            string   `protobuf:"bytes,1,opt,name=namespace,proto3" json:"namespace,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

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

func (*ListPodsRequest) XXX_DiscardUnknown

func (m *ListPodsRequest) XXX_DiscardUnknown()

func (*ListPodsRequest) XXX_Marshal

func (m *ListPodsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ListPodsRequest) XXX_Merge

func (dst *ListPodsRequest) XXX_Merge(src proto.Message)

func (*ListPodsRequest) XXX_Size

func (m *ListPodsRequest) XXX_Size() int

func (*ListPodsRequest) XXX_Unmarshal

func (m *ListPodsRequest) XXX_Unmarshal(b []byte) error

type ListPodsResponse

type ListPodsResponse struct {
	Pods                 []*Pod   `protobuf:"bytes,1,rep,name=pods,proto3" json:"pods,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

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

func (*ListPodsResponse) XXX_DiscardUnknown

func (m *ListPodsResponse) XXX_DiscardUnknown()

func (*ListPodsResponse) XXX_Marshal

func (m *ListPodsResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ListPodsResponse) XXX_Merge

func (dst *ListPodsResponse) XXX_Merge(src proto.Message)

func (*ListPodsResponse) XXX_Size

func (m *ListPodsResponse) XXX_Size() int

func (*ListPodsResponse) XXX_Unmarshal

func (m *ListPodsResponse) XXX_Unmarshal(b []byte) error

type Pod

type Pod struct {
	Name  string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	PodIP string `protobuf:"bytes,2,opt,name=podIP,proto3" 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,proto3" json:"status,omitempty"`
	Added                bool               `protobuf:"varint,5,opt,name=added,proto3" json:"added,omitempty"`
	SinceLastReport      *duration.Duration `protobuf:"bytes,6,opt,name=sinceLastReport,proto3" json:"sinceLastReport,omitempty"`
	ControllerNamespace  string             `protobuf:"bytes,7,opt,name=controllerNamespace,proto3" json:"controllerNamespace,omitempty"`
	ControlPlane         bool               `protobuf:"varint,8,opt,name=controlPlane,proto3" json:"controlPlane,omitempty"`
	Uptime               *duration.Duration `protobuf:"bytes,9,opt,name=uptime,proto3" json:"uptime,omitempty"`
	XXX_NoUnkeyedLiteral struct{}           `json:"-"`
	XXX_unrecognized     []byte             `json:"-"`
	XXX_sizecache        int32              `json:"-"`
}

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() *duration.Duration

func (*Pod) GetStatefulSet

func (m *Pod) GetStatefulSet() string

func (*Pod) GetStatus

func (m *Pod) GetStatus() string

func (*Pod) GetUptime

func (m *Pod) GetUptime() *duration.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_DiscardUnknown

func (m *Pod) XXX_DiscardUnknown()

func (*Pod) XXX_Marshal

func (m *Pod) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Pod) XXX_Merge

func (dst *Pod) XXX_Merge(src proto.Message)

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.

func (*Pod) XXX_Size

func (m *Pod) XXX_Size() int

func (*Pod) XXX_Unmarshal

func (m *Pod) XXX_Unmarshal(b []byte) error

type PodErrors

type PodErrors struct {
	Errors               []*PodErrors_PodError `protobuf:"bytes,1,rep,name=errors,proto3" json:"errors,omitempty"`
	XXX_NoUnkeyedLiteral struct{}              `json:"-"`
	XXX_unrecognized     []byte                `json:"-"`
	XXX_sizecache        int32                 `json:"-"`
}

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

func (*PodErrors) XXX_DiscardUnknown

func (m *PodErrors) XXX_DiscardUnknown()

func (*PodErrors) XXX_Marshal

func (m *PodErrors) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*PodErrors) XXX_Merge

func (dst *PodErrors) XXX_Merge(src proto.Message)

func (*PodErrors) XXX_Size

func (m *PodErrors) XXX_Size() int

func (*PodErrors) XXX_Unmarshal

func (m *PodErrors) XXX_Unmarshal(b []byte) error

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"`
	XXX_NoUnkeyedLiteral struct{}                   `json:"-"`
	XXX_unrecognized     []byte                     `json:"-"`
	XXX_sizecache        int32                      `json:"-"`
}

func (*PodErrors_PodError) Descriptor

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

func (*PodErrors_PodError) GetContainer

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_DiscardUnknown

func (m *PodErrors_PodError) XXX_DiscardUnknown()

func (*PodErrors_PodError) XXX_Marshal

func (m *PodErrors_PodError) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*PodErrors_PodError) XXX_Merge

func (dst *PodErrors_PodError) XXX_Merge(src proto.Message)

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.

func (*PodErrors_PodError) XXX_Size

func (m *PodErrors_PodError) XXX_Size() int

func (*PodErrors_PodError) XXX_Unmarshal

func (m *PodErrors_PodError) XXX_Unmarshal(b []byte) error

type PodErrors_PodError_Container

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

type PodErrors_PodError_ContainerError

type PodErrors_PodError_ContainerError struct {
	Message              string   `protobuf:"bytes,1,opt,name=message,proto3" json:"message,omitempty"`
	Container            string   `protobuf:"bytes,2,opt,name=container,proto3" json:"container,omitempty"`
	Image                string   `protobuf:"bytes,3,opt,name=image,proto3" json:"image,omitempty"`
	Reason               string   `protobuf:"bytes,4,opt,name=reason,proto3" json:"reason,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

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 (*PodErrors_PodError_ContainerError) GetMessage

func (m *PodErrors_PodError_ContainerError) GetMessage() string

func (*PodErrors_PodError_ContainerError) GetReason

func (*PodErrors_PodError_ContainerError) ProtoMessage

func (*PodErrors_PodError_ContainerError) ProtoMessage()

func (*PodErrors_PodError_ContainerError) Reset

func (*PodErrors_PodError_ContainerError) String

func (*PodErrors_PodError_ContainerError) XXX_DiscardUnknown

func (m *PodErrors_PodError_ContainerError) XXX_DiscardUnknown()

func (*PodErrors_PodError_ContainerError) XXX_Marshal

func (m *PodErrors_PodError_ContainerError) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*PodErrors_PodError_ContainerError) XXX_Merge

func (dst *PodErrors_PodError_ContainerError) XXX_Merge(src proto.Message)

func (*PodErrors_PodError_ContainerError) XXX_Size

func (m *PodErrors_PodError_ContainerError) XXX_Size() int

func (*PodErrors_PodError_ContainerError) XXX_Unmarshal

func (m *PodErrors_PodError_ContainerError) XXX_Unmarshal(b []byte) error

type Pod_DaemonSet

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

type Pod_Deployment

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

type Pod_Job

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

type Pod_ReplicaSet

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

type Pod_ReplicationController

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

type Pod_StatefulSet

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

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,proto3" 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,proto3" json:"type,omitempty"`
	// An optional resource name.
	Name                 string   `protobuf:"bytes,3,opt,name=name,proto3" json:"name,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

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

func (*Resource) XXX_DiscardUnknown

func (m *Resource) XXX_DiscardUnknown()

func (*Resource) XXX_Marshal

func (m *Resource) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Resource) XXX_Merge

func (dst *Resource) XXX_Merge(src proto.Message)

func (*Resource) XXX_Size

func (m *Resource) XXX_Size() int

func (*Resource) XXX_Unmarshal

func (m *Resource) XXX_Unmarshal(b []byte) error

type ResourceError

type ResourceError struct {
	Resource             *Resource `protobuf:"bytes,1,opt,name=resource,proto3" json:"resource,omitempty"`
	Error                string    `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty"`
	XXX_NoUnkeyedLiteral struct{}  `json:"-"`
	XXX_unrecognized     []byte    `json:"-"`
	XXX_sizecache        int32     `json:"-"`
}

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

func (*ResourceError) XXX_DiscardUnknown

func (m *ResourceError) XXX_DiscardUnknown()

func (*ResourceError) XXX_Marshal

func (m *ResourceError) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ResourceError) XXX_Merge

func (dst *ResourceError) XXX_Merge(src proto.Message)

func (*ResourceError) XXX_Size

func (m *ResourceError) XXX_Size() int

func (*ResourceError) XXX_Unmarshal

func (m *ResourceError) XXX_Unmarshal(b []byte) error

type ResourceSelection

type ResourceSelection struct {
	// Identifies a Kubernetes resource.
	Resource *Resource `protobuf:"bytes,1,opt,name=resource,proto3" 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,proto3" json:"label_selector,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

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

func (*ResourceSelection) XXX_DiscardUnknown

func (m *ResourceSelection) XXX_DiscardUnknown()

func (*ResourceSelection) XXX_Marshal

func (m *ResourceSelection) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ResourceSelection) XXX_Merge

func (dst *ResourceSelection) XXX_Merge(src proto.Message)

func (*ResourceSelection) XXX_Size

func (m *ResourceSelection) XXX_Size() int

func (*ResourceSelection) XXX_Unmarshal

func (m *ResourceSelection) XXX_Unmarshal(b []byte) error

type Scheme

type Scheme struct {
	// Types that are valid to be assigned to Type:
	//	*Scheme_Registered_
	//	*Scheme_Unregistered
	Type                 isScheme_Type `protobuf_oneof:"type"`
	XXX_NoUnkeyedLiteral struct{}      `json:"-"`
	XXX_unrecognized     []byte        `json:"-"`
	XXX_sizecache        int32         `json:"-"`
}

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_DiscardUnknown

func (m *Scheme) XXX_DiscardUnknown()

func (*Scheme) XXX_Marshal

func (m *Scheme) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Scheme) XXX_Merge

func (dst *Scheme) XXX_Merge(src proto.Message)

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.

func (*Scheme) XXX_Size

func (m *Scheme) XXX_Size() int

func (*Scheme) XXX_Unmarshal

func (m *Scheme) XXX_Unmarshal(b []byte) error

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,proto3,enum=linkerd2.public.Scheme_Registered,oneof"`
}

type Scheme_Unregistered

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

type StatSummaryRequest

type StatSummaryRequest struct {
	Selector   *ResourceSelection `protobuf:"bytes,1,opt,name=selector,proto3" json:"selector,omitempty"`
	TimeWindow string             `protobuf:"bytes,2,opt,name=time_window,json=timeWindow,proto3" 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"`
	XXX_NoUnkeyedLiteral struct{}                      `json:"-"`
	XXX_unrecognized     []byte                        `json:"-"`
	XXX_sizecache        int32                         `json:"-"`
}

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_DiscardUnknown

func (m *StatSummaryRequest) XXX_DiscardUnknown()

func (*StatSummaryRequest) XXX_Marshal

func (m *StatSummaryRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*StatSummaryRequest) XXX_Merge

func (dst *StatSummaryRequest) XXX_Merge(src proto.Message)

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.

func (*StatSummaryRequest) XXX_Size

func (m *StatSummaryRequest) XXX_Size() int

func (*StatSummaryRequest) XXX_Unmarshal

func (m *StatSummaryRequest) XXX_Unmarshal(b []byte) error

type StatSummaryRequest_FromResource

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

type StatSummaryRequest_None

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

type StatSummaryRequest_ToResource

type StatSummaryRequest_ToResource struct {
	ToResource *Resource `protobuf:"bytes,4,opt,name=to_resource,json=toResource,proto3,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"`
	XXX_NoUnkeyedLiteral struct{}                       `json:"-"`
	XXX_unrecognized     []byte                         `json:"-"`
	XXX_sizecache        int32                          `json:"-"`
}

func (*StatSummaryResponse) Descriptor

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

func (*StatSummaryResponse) GetError

func (m *StatSummaryResponse) GetError() *ResourceError

func (*StatSummaryResponse) GetOk

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_DiscardUnknown

func (m *StatSummaryResponse) XXX_DiscardUnknown()

func (*StatSummaryResponse) XXX_Marshal

func (m *StatSummaryResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*StatSummaryResponse) XXX_Merge

func (dst *StatSummaryResponse) XXX_Merge(src proto.Message)

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.

func (*StatSummaryResponse) XXX_Size

func (m *StatSummaryResponse) XXX_Size() int

func (*StatSummaryResponse) XXX_Unmarshal

func (m *StatSummaryResponse) XXX_Unmarshal(b []byte) error

type StatSummaryResponse_Error

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

type StatSummaryResponse_Ok

type StatSummaryResponse_Ok struct {
	StatTables           []*StatTable `protobuf:"bytes,1,rep,name=stat_tables,json=statTables,proto3" json:"stat_tables,omitempty"`
	XXX_NoUnkeyedLiteral struct{}     `json:"-"`
	XXX_unrecognized     []byte       `json:"-"`
	XXX_sizecache        int32        `json:"-"`
}

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

func (*StatSummaryResponse_Ok) XXX_DiscardUnknown

func (m *StatSummaryResponse_Ok) XXX_DiscardUnknown()

func (*StatSummaryResponse_Ok) XXX_Marshal

func (m *StatSummaryResponse_Ok) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*StatSummaryResponse_Ok) XXX_Merge

func (dst *StatSummaryResponse_Ok) XXX_Merge(src proto.Message)

func (*StatSummaryResponse_Ok) XXX_Size

func (m *StatSummaryResponse_Ok) XXX_Size() int

func (*StatSummaryResponse_Ok) XXX_Unmarshal

func (m *StatSummaryResponse_Ok) XXX_Unmarshal(b []byte) error

type StatSummaryResponse_Ok_

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

type StatTable

type StatTable struct {
	// Types that are valid to be assigned to Table:
	//	*StatTable_PodGroup_
	Table                isStatTable_Table `protobuf_oneof:"table"`
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

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_DiscardUnknown

func (m *StatTable) XXX_DiscardUnknown()

func (*StatTable) XXX_Marshal

func (m *StatTable) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*StatTable) XXX_Merge

func (dst *StatTable) XXX_Merge(src proto.Message)

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.

func (*StatTable) XXX_Size

func (m *StatTable) XXX_Size() int

func (*StatTable) XXX_Unmarshal

func (m *StatTable) XXX_Unmarshal(b []byte) error

type StatTable_PodGroup

type StatTable_PodGroup struct {
	Rows                 []*StatTable_PodGroup_Row `protobuf:"bytes,1,rep,name=rows,proto3" json:"rows,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                  `json:"-"`
	XXX_unrecognized     []byte                    `json:"-"`
	XXX_sizecache        int32                     `json:"-"`
}

func (*StatTable_PodGroup) Descriptor

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

func (*StatTable_PodGroup) GetRows

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

func (*StatTable_PodGroup) XXX_DiscardUnknown

func (m *StatTable_PodGroup) XXX_DiscardUnknown()

func (*StatTable_PodGroup) XXX_Marshal

func (m *StatTable_PodGroup) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*StatTable_PodGroup) XXX_Merge

func (dst *StatTable_PodGroup) XXX_Merge(src proto.Message)

func (*StatTable_PodGroup) XXX_Size

func (m *StatTable_PodGroup) XXX_Size() int

func (*StatTable_PodGroup) XXX_Unmarshal

func (m *StatTable_PodGroup) XXX_Unmarshal(b []byte) error

type StatTable_PodGroup_

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

type StatTable_PodGroup_Row

type StatTable_PodGroup_Row struct {
	Resource   *Resource `protobuf:"bytes,1,opt,name=resource,proto3" json:"resource,omitempty"`
	TimeWindow string    `protobuf:"bytes,2,opt,name=time_window,json=timeWindow,proto3" 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,proto3" 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,proto3" 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,proto3" json:"failed_pod_count,omitempty"`
	Stats          *BasicStats `protobuf:"bytes,5,opt,name=stats,proto3" 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 `` /* 184-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{}              `json:"-"`
	XXX_unrecognized     []byte                `json:"-"`
	XXX_sizecache        int32                 `json:"-"`
}

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

func (*StatTable_PodGroup_Row) XXX_DiscardUnknown

func (m *StatTable_PodGroup_Row) XXX_DiscardUnknown()

func (*StatTable_PodGroup_Row) XXX_Marshal

func (m *StatTable_PodGroup_Row) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*StatTable_PodGroup_Row) XXX_Merge

func (dst *StatTable_PodGroup_Row) XXX_Merge(src proto.Message)

func (*StatTable_PodGroup_Row) XXX_Size

func (m *StatTable_PodGroup_Row) XXX_Size() int

func (*StatTable_PodGroup_Row) XXX_Unmarshal

func (m *StatTable_PodGroup_Row) XXX_Unmarshal(b []byte) error

type TapByResourceRequest

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

A tap request over kubernetes resources.

func (*TapByResourceRequest) Descriptor

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

func (*TapByResourceRequest) GetMatch

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

func (*TapByResourceRequest) XXX_DiscardUnknown

func (m *TapByResourceRequest) XXX_DiscardUnknown()

func (*TapByResourceRequest) XXX_Marshal

func (m *TapByResourceRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*TapByResourceRequest) XXX_Merge

func (dst *TapByResourceRequest) XXX_Merge(src proto.Message)

func (*TapByResourceRequest) XXX_Size

func (m *TapByResourceRequest) XXX_Size() int

func (*TapByResourceRequest) XXX_Unmarshal

func (m *TapByResourceRequest) XXX_Unmarshal(b []byte) error

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"`
	XXX_NoUnkeyedLiteral struct{}                           `json:"-"`
	XXX_unrecognized     []byte                             `json:"-"`
	XXX_sizecache        int32                              `json:"-"`
}

func (*TapByResourceRequest_Match) Descriptor

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

func (*TapByResourceRequest_Match) GetAll

func (*TapByResourceRequest_Match) GetAny

func (*TapByResourceRequest_Match) GetDestinations

func (m *TapByResourceRequest_Match) GetDestinations() *ResourceSelection

func (*TapByResourceRequest_Match) GetHttp

func (*TapByResourceRequest_Match) GetMatch

func (m *TapByResourceRequest_Match) GetMatch() isTapByResourceRequest_Match_Match

func (*TapByResourceRequest_Match) GetNot

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_DiscardUnknown

func (m *TapByResourceRequest_Match) XXX_DiscardUnknown()

func (*TapByResourceRequest_Match) XXX_Marshal

func (m *TapByResourceRequest_Match) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*TapByResourceRequest_Match) XXX_Merge

func (dst *TapByResourceRequest_Match) XXX_Merge(src proto.Message)

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.

func (*TapByResourceRequest_Match) XXX_Size

func (m *TapByResourceRequest_Match) XXX_Size() int

func (*TapByResourceRequest_Match) XXX_Unmarshal

func (m *TapByResourceRequest_Match) XXX_Unmarshal(b []byte) error

type TapByResourceRequest_Match_All

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

type TapByResourceRequest_Match_Any

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

type TapByResourceRequest_Match_Destinations

type TapByResourceRequest_Match_Destinations struct {
	Destinations *ResourceSelection `protobuf:"bytes,4,opt,name=destinations,proto3,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"`
	XXX_NoUnkeyedLiteral struct{}                                `json:"-"`
	XXX_unrecognized     []byte                                  `json:"-"`
	XXX_sizecache        int32                                   `json:"-"`
}

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

func (*TapByResourceRequest_Match_Http) XXX_DiscardUnknown

func (m *TapByResourceRequest_Match_Http) XXX_DiscardUnknown()

func (*TapByResourceRequest_Match_Http) XXX_Marshal

func (m *TapByResourceRequest_Match_Http) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*TapByResourceRequest_Match_Http) XXX_Merge

func (dst *TapByResourceRequest_Match_Http) XXX_Merge(src proto.Message)

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.

func (*TapByResourceRequest_Match_Http) XXX_Size

func (m *TapByResourceRequest_Match_Http) XXX_Size() int

func (*TapByResourceRequest_Match_Http) XXX_Unmarshal

func (m *TapByResourceRequest_Match_Http) XXX_Unmarshal(b []byte) error

type TapByResourceRequest_Match_Http_

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

type TapByResourceRequest_Match_Http_Authority

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

type TapByResourceRequest_Match_Http_Method

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

type TapByResourceRequest_Match_Http_Path

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

type TapByResourceRequest_Match_Http_Scheme

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

type TapByResourceRequest_Match_Not

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

type TapByResourceRequest_Match_Seq

type TapByResourceRequest_Match_Seq struct {
	Matches              []*TapByResourceRequest_Match `protobuf:"bytes,1,rep,name=matches,proto3" json:"matches,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                      `json:"-"`
	XXX_unrecognized     []byte                        `json:"-"`
	XXX_sizecache        int32                         `json:"-"`
}

func (*TapByResourceRequest_Match_Seq) Descriptor

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

func (*TapByResourceRequest_Match_Seq) GetMatches

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 (*TapByResourceRequest_Match_Seq) XXX_DiscardUnknown

func (m *TapByResourceRequest_Match_Seq) XXX_DiscardUnknown()

func (*TapByResourceRequest_Match_Seq) XXX_Marshal

func (m *TapByResourceRequest_Match_Seq) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*TapByResourceRequest_Match_Seq) XXX_Merge

func (dst *TapByResourceRequest_Match_Seq) XXX_Merge(src proto.Message)

func (*TapByResourceRequest_Match_Seq) XXX_Size

func (m *TapByResourceRequest_Match_Seq) XXX_Size() int

func (*TapByResourceRequest_Match_Seq) XXX_Unmarshal

func (m *TapByResourceRequest_Match_Seq) XXX_Unmarshal(b []byte) error

type TapEvent

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

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_DiscardUnknown

func (m *TapEvent) XXX_DiscardUnknown()

func (*TapEvent) XXX_Marshal

func (m *TapEvent) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*TapEvent) XXX_Merge

func (dst *TapEvent) XXX_Merge(src proto.Message)

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.

func (*TapEvent) XXX_Size

func (m *TapEvent) XXX_Size() int

func (*TapEvent) XXX_Unmarshal

func (m *TapEvent) XXX_Unmarshal(b []byte) error

type TapEvent_EndpointMeta

type TapEvent_EndpointMeta struct {
	Labels               map[string]string `` /* 153-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

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

func (*TapEvent_EndpointMeta) XXX_DiscardUnknown

func (m *TapEvent_EndpointMeta) XXX_DiscardUnknown()

func (*TapEvent_EndpointMeta) XXX_Marshal

func (m *TapEvent_EndpointMeta) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*TapEvent_EndpointMeta) XXX_Merge

func (dst *TapEvent_EndpointMeta) XXX_Merge(src proto.Message)

func (*TapEvent_EndpointMeta) XXX_Size

func (m *TapEvent_EndpointMeta) XXX_Size() int

func (*TapEvent_EndpointMeta) XXX_Unmarshal

func (m *TapEvent_EndpointMeta) XXX_Unmarshal(b []byte) error

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"`
	XXX_NoUnkeyedLiteral struct{}              `json:"-"`
	XXX_unrecognized     []byte                `json:"-"`
	XXX_sizecache        int32                 `json:"-"`
}

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_DiscardUnknown

func (m *TapEvent_Http) XXX_DiscardUnknown()

func (*TapEvent_Http) XXX_Marshal

func (m *TapEvent_Http) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*TapEvent_Http) XXX_Merge

func (dst *TapEvent_Http) XXX_Merge(src proto.Message)

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.

func (*TapEvent_Http) XXX_Size

func (m *TapEvent_Http) XXX_Size() int

func (*TapEvent_Http) XXX_Unmarshal

func (m *TapEvent_Http) XXX_Unmarshal(b []byte) error

type TapEvent_Http_

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

type TapEvent_Http_RequestInit

type TapEvent_Http_RequestInit struct {
	Id                   *TapEvent_Http_StreamId `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Method               *HttpMethod             `protobuf:"bytes,2,opt,name=method,proto3" json:"method,omitempty"`
	Scheme               *Scheme                 `protobuf:"bytes,3,opt,name=scheme,proto3" json:"scheme,omitempty"`
	Authority            string                  `protobuf:"bytes,4,opt,name=authority,proto3" json:"authority,omitempty"`
	Path                 string                  `protobuf:"bytes,5,opt,name=path,proto3" json:"path,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                `json:"-"`
	XXX_unrecognized     []byte                  `json:"-"`
	XXX_sizecache        int32                   `json:"-"`
}

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 (*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

func (*TapEvent_Http_RequestInit) XXX_DiscardUnknown

func (m *TapEvent_Http_RequestInit) XXX_DiscardUnknown()

func (*TapEvent_Http_RequestInit) XXX_Marshal

func (m *TapEvent_Http_RequestInit) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*TapEvent_Http_RequestInit) XXX_Merge

func (dst *TapEvent_Http_RequestInit) XXX_Merge(src proto.Message)

func (*TapEvent_Http_RequestInit) XXX_Size

func (m *TapEvent_Http_RequestInit) XXX_Size() int

func (*TapEvent_Http_RequestInit) XXX_Unmarshal

func (m *TapEvent_Http_RequestInit) XXX_Unmarshal(b []byte) error

type TapEvent_Http_RequestInit_

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

type TapEvent_Http_ResponseEnd

type TapEvent_Http_ResponseEnd struct {
	Id                   *TapEvent_Http_StreamId `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	SinceRequestInit     *duration.Duration      `protobuf:"bytes,2,opt,name=since_request_init,json=sinceRequestInit,proto3" json:"since_request_init,omitempty"`
	SinceResponseInit    *duration.Duration      `protobuf:"bytes,3,opt,name=since_response_init,json=sinceResponseInit,proto3" json:"since_response_init,omitempty"`
	ResponseBytes        uint64                  `protobuf:"varint,4,opt,name=response_bytes,json=responseBytes,proto3" json:"response_bytes,omitempty"`
	Eos                  *Eos                    `protobuf:"bytes,5,opt,name=eos,proto3" json:"eos,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                `json:"-"`
	XXX_unrecognized     []byte                  `json:"-"`
	XXX_sizecache        int32                   `json:"-"`
}

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 (*TapEvent_Http_ResponseEnd) GetResponseBytes

func (m *TapEvent_Http_ResponseEnd) GetResponseBytes() uint64

func (*TapEvent_Http_ResponseEnd) GetSinceRequestInit

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

func (*TapEvent_Http_ResponseEnd) GetSinceResponseInit

func (m *TapEvent_Http_ResponseEnd) GetSinceResponseInit() *duration.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

func (*TapEvent_Http_ResponseEnd) XXX_DiscardUnknown

func (m *TapEvent_Http_ResponseEnd) XXX_DiscardUnknown()

func (*TapEvent_Http_ResponseEnd) XXX_Marshal

func (m *TapEvent_Http_ResponseEnd) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*TapEvent_Http_ResponseEnd) XXX_Merge

func (dst *TapEvent_Http_ResponseEnd) XXX_Merge(src proto.Message)

func (*TapEvent_Http_ResponseEnd) XXX_Size

func (m *TapEvent_Http_ResponseEnd) XXX_Size() int

func (*TapEvent_Http_ResponseEnd) XXX_Unmarshal

func (m *TapEvent_Http_ResponseEnd) XXX_Unmarshal(b []byte) error

type TapEvent_Http_ResponseEnd_

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

type TapEvent_Http_ResponseInit

type TapEvent_Http_ResponseInit struct {
	Id                   *TapEvent_Http_StreamId `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	SinceRequestInit     *duration.Duration      `protobuf:"bytes,2,opt,name=since_request_init,json=sinceRequestInit,proto3" json:"since_request_init,omitempty"`
	HttpStatus           uint32                  `protobuf:"varint,3,opt,name=http_status,json=httpStatus,proto3" json:"http_status,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                `json:"-"`
	XXX_unrecognized     []byte                  `json:"-"`
	XXX_sizecache        int32                   `json:"-"`
}

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 (*TapEvent_Http_ResponseInit) GetSinceRequestInit

func (m *TapEvent_Http_ResponseInit) GetSinceRequestInit() *duration.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

func (*TapEvent_Http_ResponseInit) XXX_DiscardUnknown

func (m *TapEvent_Http_ResponseInit) XXX_DiscardUnknown()

func (*TapEvent_Http_ResponseInit) XXX_Marshal

func (m *TapEvent_Http_ResponseInit) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*TapEvent_Http_ResponseInit) XXX_Merge

func (dst *TapEvent_Http_ResponseInit) XXX_Merge(src proto.Message)

func (*TapEvent_Http_ResponseInit) XXX_Size

func (m *TapEvent_Http_ResponseInit) XXX_Size() int

func (*TapEvent_Http_ResponseInit) XXX_Unmarshal

func (m *TapEvent_Http_ResponseInit) XXX_Unmarshal(b []byte) error

type TapEvent_Http_ResponseInit_

type TapEvent_Http_ResponseInit_ struct {
	ResponseInit *TapEvent_Http_ResponseInit `protobuf:"bytes,2,opt,name=response_init,json=responseInit,proto3,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,proto3" json:"base,omitempty"`
	// A stream id unique within the lifetime of `base`.
	Stream               uint64   `protobuf:"varint,2,opt,name=stream,proto3" json:"stream,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

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

func (*TapEvent_Http_StreamId) XXX_DiscardUnknown

func (m *TapEvent_Http_StreamId) XXX_DiscardUnknown()

func (*TapEvent_Http_StreamId) XXX_Marshal

func (m *TapEvent_Http_StreamId) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*TapEvent_Http_StreamId) XXX_Merge

func (dst *TapEvent_Http_StreamId) XXX_Merge(src proto.Message)

func (*TapEvent_Http_StreamId) XXX_Size

func (m *TapEvent_Http_StreamId) XXX_Size() int

func (*TapEvent_Http_StreamId) XXX_Unmarshal

func (m *TapEvent_Http_StreamId) XXX_Unmarshal(b []byte) error

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 deprecated

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,proto3" json:"maxRps,omitempty"`
	ToPort               uint32   `protobuf:"varint,4,opt,name=toPort,proto3" json:"toPort,omitempty"`
	ToIP                 string   `protobuf:"bytes,5,opt,name=toIP,proto3" json:"toIP,omitempty"`
	FromPort             uint32   `protobuf:"varint,6,opt,name=fromPort,proto3" json:"fromPort,omitempty"`
	FromIP               string   `protobuf:"bytes,7,opt,name=fromIP,proto3" json:"fromIP,omitempty"`
	Scheme               string   `protobuf:"bytes,8,opt,name=scheme,proto3" json:"scheme,omitempty"`
	Method               string   `protobuf:"bytes,9,opt,name=method,proto3" json:"method,omitempty"`
	Authority            string   `protobuf:"bytes,10,opt,name=authority,proto3" json:"authority,omitempty"`
	Path                 string   `protobuf:"bytes,11,opt,name=path,proto3" json:"path,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Deprecated: Do not use.

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_DiscardUnknown

func (m *TapRequest) XXX_DiscardUnknown()

func (*TapRequest) XXX_Marshal

func (m *TapRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*TapRequest) XXX_Merge

func (dst *TapRequest) XXX_Merge(src proto.Message)

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.

func (*TapRequest) XXX_Size

func (m *TapRequest) XXX_Size() int

func (*TapRequest) XXX_Unmarshal

func (m *TapRequest) XXX_Unmarshal(b []byte) error

type TapRequest_Deployment

type TapRequest_Deployment struct {
	Deployment string `protobuf:"bytes,2,opt,name=deployment,proto3,oneof"`
}

type TapRequest_Pod

type TapRequest_Pod struct {
	Pod string `protobuf:"bytes,1,opt,name=pod,proto3,oneof"`
}

type TcpAddress

type TcpAddress struct {
	Ip                   *IPAddress `protobuf:"bytes,1,opt,name=ip,proto3" json:"ip,omitempty"`
	Port                 uint32     `protobuf:"varint,2,opt,name=port,proto3" json:"port,omitempty"`
	XXX_NoUnkeyedLiteral struct{}   `json:"-"`
	XXX_unrecognized     []byte     `json:"-"`
	XXX_sizecache        int32      `json:"-"`
}

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

func (*TcpAddress) XXX_DiscardUnknown

func (m *TcpAddress) XXX_DiscardUnknown()

func (*TcpAddress) XXX_Marshal

func (m *TcpAddress) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*TcpAddress) XXX_Merge

func (dst *TcpAddress) XXX_Merge(src proto.Message)

func (*TcpAddress) XXX_Size

func (m *TcpAddress) XXX_Size() int

func (*TcpAddress) XXX_Unmarshal

func (m *TcpAddress) XXX_Unmarshal(b []byte) error

type VersionInfo

type VersionInfo struct {
	GoVersion            string   `protobuf:"bytes,1,opt,name=goVersion,proto3" json:"goVersion,omitempty"`
	BuildDate            string   `protobuf:"bytes,2,opt,name=buildDate,proto3" json:"buildDate,omitempty"`
	ReleaseVersion       string   `protobuf:"bytes,3,opt,name=releaseVersion,proto3" json:"releaseVersion,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

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

func (*VersionInfo) XXX_DiscardUnknown

func (m *VersionInfo) XXX_DiscardUnknown()

func (*VersionInfo) XXX_Marshal

func (m *VersionInfo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*VersionInfo) XXX_Merge

func (dst *VersionInfo) XXX_Merge(src proto.Message)

func (*VersionInfo) XXX_Size

func (m *VersionInfo) XXX_Size() int

func (*VersionInfo) XXX_Unmarshal

func (m *VersionInfo) XXX_Unmarshal(b []byte) error

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL