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: 46

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

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

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

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

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

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

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

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

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

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_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 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.

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

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

type PodErrors_PodError_ContainerError added in v0.4.4 

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

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

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

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

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

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

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

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 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_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 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.

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

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

type StatSummaryRequest_None added in v0.4.0 

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

type StatSummaryRequest_ToResource added in v0.4.0 

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

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_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 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.

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

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

type StatSummaryResponse_Ok added in v0.4.0 

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

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

type StatSummaryResponse_Ok_ struct {
	Ok *StatSummaryResponse_Ok `protobuf:"bytes,1,opt,name=ok,proto3,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"`
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

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_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 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.

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

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

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

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

type StatTable_PodGroup_Row added in v0.4.0 

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

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

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

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

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_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 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.

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

type TapByResourceRequest_Match_All struct {
	All *TapByResourceRequest_Match_Seq `protobuf:"bytes,1,opt,name=all,proto3,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,proto3,oneof"`
}

type TapByResourceRequest_Match_Destinations added in v0.4.1 

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

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_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 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.

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

type TapByResourceRequest_Match_Http_ struct {
	Http *TapByResourceRequest_Match_Http `protobuf:"bytes,5,opt,name=http,proto3,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,proto3,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,proto3,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,proto3,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,proto3,oneof"`
}

type TapByResourceRequest_Match_Not added in v0.4.1 

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

type TapByResourceRequest_Match_Seq added in v0.4.1 

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

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

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 (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() *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 (m *TapEvent_Http_ResponseInit) GetId() *TapEvent_Http_StreamId

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

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.