tap

package

Go to main page

Versions in this module

v0

v0.18.0

Nov 7, 2025

v0.17.0

Aug 13, 2025

v0.16.0

Mar 31, 2025

v0.15.0

Nov 21, 2024

v0.14.0

Jul 24, 2024

v0.13.1

Apr 29, 2024

v0.13.0

Jan 5, 2024

v0.12.0

Dec 4, 2023

v0.11.0

Jul 10, 2023

v0.10.0

Jun 1, 2023

v0.9.0

Apr 10, 2023

Changes in this version

+ const Tap_Observe_FullMethodName

v0.8.0

Feb 8, 2023

v0.7.0

Aug 3, 2022

v0.6.0

Jul 13, 2022

v0.5.0

Apr 10, 2022

v0.4.0

Apr 7, 2022

v0.3.1

Dec 21, 2021

v0.3.0

Oct 27, 2021

v0.2.0

Jul 16, 2021

Changes in this version

+ var Tap_ServiceDesc = grpc.ServiceDesc

+ type UnsafeTapServer interface

v0.1.18

Jan 15, 2021

v0.1.17

Jan 10, 2021

v0.1.16

Dec 22, 2020

v0.1.15

Nov 14, 2020

v0.1.14

Sep 29, 2020

v0.1.13

Jun 23, 2020

Changes in this version

+ var File_tap_proto protoreflect.FileDescriptor

type Eos

+ func (x *Eos) ProtoReflect() protoreflect.Message

type ObserveRequest

+ func (x *ObserveRequest) ProtoReflect() protoreflect.Message

type ObserveRequest_Extract

+ func (x *ObserveRequest_Extract) ProtoReflect() protoreflect.Message

type ObserveRequest_Extract_Http

+ func (x *ObserveRequest_Extract_Http) ProtoReflect() protoreflect.Message

type ObserveRequest_Extract_Http_Headers

+ func (x *ObserveRequest_Extract_Http_Headers) ProtoReflect() protoreflect.Message

type ObserveRequest_Match

+ func (x *ObserveRequest_Match) ProtoReflect() protoreflect.Message

type ObserveRequest_Match_Http

+ func (x *ObserveRequest_Match_Http) ProtoReflect() protoreflect.Message

type ObserveRequest_Match_Http_StringMatch

+ func (x *ObserveRequest_Match_Http_StringMatch) ProtoReflect() protoreflect.Message

type ObserveRequest_Match_Label

+ func (x *ObserveRequest_Match_Label) ProtoReflect() protoreflect.Message

type ObserveRequest_Match_Seq

+ func (x *ObserveRequest_Match_Seq) ProtoReflect() protoreflect.Message

type ObserveRequest_Match_Tcp

+ func (x *ObserveRequest_Match_Tcp) ProtoReflect() protoreflect.Message

type ObserveRequest_Match_Tcp_Netmask

+ func (x *ObserveRequest_Match_Tcp_Netmask) ProtoReflect() protoreflect.Message

type ObserveRequest_Match_Tcp_PortRange

+ func (x *ObserveRequest_Match_Tcp_PortRange) ProtoReflect() protoreflect.Message

type TapEvent

+ func (x *TapEvent) ProtoReflect() protoreflect.Message

type TapEvent_EndpointMeta

+ func (x *TapEvent_EndpointMeta) ProtoReflect() protoreflect.Message

type TapEvent_Http

+ func (x *TapEvent_Http) ProtoReflect() protoreflect.Message

type TapEvent_Http_RequestInit

+ func (x *TapEvent_Http_RequestInit) ProtoReflect() protoreflect.Message

type TapEvent_Http_ResponseEnd

+ func (x *TapEvent_Http_ResponseEnd) ProtoReflect() protoreflect.Message

type TapEvent_Http_ResponseInit

+ func (x *TapEvent_Http_ResponseInit) ProtoReflect() protoreflect.Message

type TapEvent_Http_StreamId

+ func (x *TapEvent_Http_StreamId) ProtoReflect() protoreflect.Message

type TapEvent_ProxyDirection

+ func (TapEvent_ProxyDirection) Descriptor() protoreflect.EnumDescriptor

+ func (TapEvent_ProxyDirection) Type() protoreflect.EnumType

+ func (x TapEvent_ProxyDirection) Enum() *TapEvent_ProxyDirection

+ func (x TapEvent_ProxyDirection) Number() protoreflect.EnumNumber

type TapEvent_RouteMeta

+ func (x *TapEvent_RouteMeta) ProtoReflect() protoreflect.Message

+ type UnimplementedTapServer struct

+ func (*UnimplementedTapServer) Observe(*ObserveRequest, Tap_ObserveServer) error

v0.1.12

Mar 25, 2020

v0.1.11

Nov 12, 2019

v0.1.10

Sep 27, 2019

Changes in this version

type ObserveRequest

+ Extract *ObserveRequest_Extract

+ func (m *ObserveRequest) GetExtract() *ObserveRequest_Extract

+ type ObserveRequest_Extract struct

+ Extract isObserveRequest_Extract_Extract

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*ObserveRequest_Extract) Descriptor() ([]byte, []int)

+ func (*ObserveRequest_Extract) ProtoMessage()

+ func (*ObserveRequest_Extract) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, ...)

+ func (dst *ObserveRequest_Extract) XXX_Merge(src proto.Message)

+ func (m *ObserveRequest_Extract) GetExtract() isObserveRequest_Extract_Extract

+ func (m *ObserveRequest_Extract) GetHttp() *ObserveRequest_Extract_Http

+ func (m *ObserveRequest_Extract) Reset()

+ func (m *ObserveRequest_Extract) String() string

+ func (m *ObserveRequest_Extract) XXX_DiscardUnknown()

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

+ func (m *ObserveRequest_Extract) XXX_Size() int

+ func (m *ObserveRequest_Extract) XXX_Unmarshal(b []byte) error

+ type ObserveRequest_Extract_Http struct

+ Extract isObserveRequest_Extract_Http_Extract

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*ObserveRequest_Extract_Http) Descriptor() ([]byte, []int)

+ func (*ObserveRequest_Extract_Http) ProtoMessage()

+ func (*ObserveRequest_Extract_Http) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, ...)

+ func (dst *ObserveRequest_Extract_Http) XXX_Merge(src proto.Message)

+ func (m *ObserveRequest_Extract_Http) GetExtract() isObserveRequest_Extract_Http_Extract

+ func (m *ObserveRequest_Extract_Http) GetHeaders() *ObserveRequest_Extract_Http_Headers

+ func (m *ObserveRequest_Extract_Http) Reset()

+ func (m *ObserveRequest_Extract_Http) String() string

+ func (m *ObserveRequest_Extract_Http) XXX_DiscardUnknown()

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

+ func (m *ObserveRequest_Extract_Http) XXX_Size() int

+ func (m *ObserveRequest_Extract_Http) XXX_Unmarshal(b []byte) error

+ type ObserveRequest_Extract_Http_ struct

+ Http *ObserveRequest_Extract_Http

+ type ObserveRequest_Extract_Http_Headers struct

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*ObserveRequest_Extract_Http_Headers) Descriptor() ([]byte, []int)

+ func (*ObserveRequest_Extract_Http_Headers) ProtoMessage()

+ func (dst *ObserveRequest_Extract_Http_Headers) XXX_Merge(src proto.Message)

+ func (m *ObserveRequest_Extract_Http_Headers) Reset()

+ func (m *ObserveRequest_Extract_Http_Headers) String() string

+ func (m *ObserveRequest_Extract_Http_Headers) XXX_DiscardUnknown()

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

+ func (m *ObserveRequest_Extract_Http_Headers) XXX_Size() int

+ func (m *ObserveRequest_Extract_Http_Headers) XXX_Unmarshal(b []byte) error

+ type ObserveRequest_Extract_Http_Headers_ struct

+ Headers *ObserveRequest_Extract_Http_Headers

type TapEvent_Http_RequestInit

+ Headers *http_types.Headers

+ func (m *TapEvent_Http_RequestInit) GetHeaders() *http_types.Headers

type TapEvent_Http_ResponseEnd

+ Trailers *http_types.Headers

+ func (m *TapEvent_Http_ResponseEnd) GetTrailers() *http_types.Headers

type TapEvent_Http_ResponseInit

+ Headers *http_types.Headers

+ func (m *TapEvent_Http_ResponseInit) GetHeaders() *http_types.Headers

v0.1.9

May 29, 2019

v0.1.8

Apr 17, 2019

v0.1.7

Mar 15, 2019

v0.1.6

Feb 5, 2019

v0.1.5

Jan 23, 2019

v0.1.4

Dec 3, 2018

Changes in this version

type ObserveRequest_Match

+ func (m *ObserveRequest_Match) GetRouteLabel() *ObserveRequest_Match_Label

+ type ObserveRequest_Match_RouteLabel struct

+ RouteLabel *ObserveRequest_Match_Label

type TapEvent

+ RouteMeta *TapEvent_RouteMeta

+ func (m *TapEvent) GetRouteMeta() *TapEvent_RouteMeta

+ type TapEvent_RouteMeta struct

+ Labels map[string]string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*TapEvent_RouteMeta) Descriptor() ([]byte, []int)

+ func (*TapEvent_RouteMeta) ProtoMessage()

+ func (dst *TapEvent_RouteMeta) XXX_Merge(src proto.Message)

+ func (m *TapEvent_RouteMeta) GetLabels() map[string]string

+ func (m *TapEvent_RouteMeta) Reset()

+ func (m *TapEvent_RouteMeta) String() string

+ func (m *TapEvent_RouteMeta) XXX_DiscardUnknown()

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

+ func (m *TapEvent_RouteMeta) XXX_Size() int

+ func (m *TapEvent_RouteMeta) XXX_Unmarshal(b []byte) error

v0.1.3

Oct 29, 2018

v0.1.2

Sep 6, 2018

Changes in this version

type Eos

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (m *Eos) XXX_DiscardUnknown()

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

+ func (m *Eos) XXX_Size() int

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

type ObserveRequest

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (dst *ObserveRequest) XXX_Merge(src proto.Message)

+ func (m *ObserveRequest) XXX_DiscardUnknown()

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

+ func (m *ObserveRequest) XXX_Size() int

+ func (m *ObserveRequest) XXX_Unmarshal(b []byte) error

type ObserveRequest_Match

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (dst *ObserveRequest_Match) XXX_Merge(src proto.Message)

+ func (m *ObserveRequest_Match) XXX_DiscardUnknown()

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

+ func (m *ObserveRequest_Match) XXX_Size() int

+ func (m *ObserveRequest_Match) XXX_Unmarshal(b []byte) error

type ObserveRequest_Match_Http

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (dst *ObserveRequest_Match_Http) XXX_Merge(src proto.Message)

+ func (m *ObserveRequest_Match_Http) XXX_DiscardUnknown()

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

+ func (m *ObserveRequest_Match_Http) XXX_Size() int

+ func (m *ObserveRequest_Match_Http) XXX_Unmarshal(b []byte) error

type ObserveRequest_Match_Http_StringMatch

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (dst *ObserveRequest_Match_Http_StringMatch) XXX_Merge(src proto.Message)

+ func (m *ObserveRequest_Match_Http_StringMatch) XXX_DiscardUnknown()

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

+ func (m *ObserveRequest_Match_Http_StringMatch) XXX_Size() int

+ func (m *ObserveRequest_Match_Http_StringMatch) XXX_Unmarshal(b []byte) error

type ObserveRequest_Match_Label

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (dst *ObserveRequest_Match_Label) XXX_Merge(src proto.Message)

+ func (m *ObserveRequest_Match_Label) XXX_DiscardUnknown()

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

+ func (m *ObserveRequest_Match_Label) XXX_Size() int

+ func (m *ObserveRequest_Match_Label) XXX_Unmarshal(b []byte) error

type ObserveRequest_Match_Seq

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (dst *ObserveRequest_Match_Seq) XXX_Merge(src proto.Message)

+ func (m *ObserveRequest_Match_Seq) XXX_DiscardUnknown()

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

+ func (m *ObserveRequest_Match_Seq) XXX_Size() int

+ func (m *ObserveRequest_Match_Seq) XXX_Unmarshal(b []byte) error

type ObserveRequest_Match_Tcp

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (dst *ObserveRequest_Match_Tcp) XXX_Merge(src proto.Message)

+ func (m *ObserveRequest_Match_Tcp) XXX_DiscardUnknown()

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

+ func (m *ObserveRequest_Match_Tcp) XXX_Size() int

+ func (m *ObserveRequest_Match_Tcp) XXX_Unmarshal(b []byte) error

type ObserveRequest_Match_Tcp_Netmask

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (dst *ObserveRequest_Match_Tcp_Netmask) XXX_Merge(src proto.Message)

+ func (m *ObserveRequest_Match_Tcp_Netmask) XXX_DiscardUnknown()

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

+ func (m *ObserveRequest_Match_Tcp_Netmask) XXX_Size() int

+ func (m *ObserveRequest_Match_Tcp_Netmask) XXX_Unmarshal(b []byte) error

type ObserveRequest_Match_Tcp_PortRange

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (dst *ObserveRequest_Match_Tcp_PortRange) XXX_Merge(src proto.Message)

+ func (m *ObserveRequest_Match_Tcp_PortRange) XXX_DiscardUnknown()

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

+ func (m *ObserveRequest_Match_Tcp_PortRange) XXX_Size() int

+ func (m *ObserveRequest_Match_Tcp_PortRange) XXX_Unmarshal(b []byte) error

type TapEvent

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (m *TapEvent) XXX_DiscardUnknown()

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

+ func (m *TapEvent) XXX_Size() int

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

type TapEvent_EndpointMeta

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (m *TapEvent_EndpointMeta) XXX_DiscardUnknown()

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

+ func (m *TapEvent_EndpointMeta) XXX_Size() int

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

type TapEvent_Http

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (m *TapEvent_Http) XXX_DiscardUnknown()

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

+ func (m *TapEvent_Http) XXX_Size() int

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

type TapEvent_Http_RequestInit

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (m *TapEvent_Http_RequestInit) XXX_DiscardUnknown()

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

+ func (m *TapEvent_Http_RequestInit) XXX_Size() int

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

type TapEvent_Http_ResponseEnd

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (m *TapEvent_Http_ResponseEnd) XXX_DiscardUnknown()

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

+ func (m *TapEvent_Http_ResponseEnd) XXX_Size() int

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

type TapEvent_Http_ResponseInit

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (m *TapEvent_Http_ResponseInit) XXX_DiscardUnknown()

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

+ func (m *TapEvent_Http_ResponseInit) XXX_Size() int

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

type TapEvent_Http_StreamId

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (m *TapEvent_Http_StreamId) XXX_DiscardUnknown()

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

+ func (m *TapEvent_Http_StreamId) XXX_Size() int

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

v0.1.1

Aug 3, 2018

Changes in this version

+ var HttpMethod_Registered_name = map[int32]string

+ var HttpMethod_Registered_value = map[string]int32

+ var Scheme_Registered_name = map[int32]string

+ var Scheme_Registered_value = map[string]int32

+ var TapEvent_ProxyDirection_name = map[int32]string

+ var TapEvent_ProxyDirection_value = map[string]int32

+ func RegisterTapServer(s *grpc.Server, srv TapServer)

+ type Eos struct

+ End isEos_End

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

+ func (*Eos) ProtoMessage()

+ func (*Eos) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, ...)

+ func (m *Eos) GetEnd() isEos_End

+ func (m *Eos) GetGrpcStatusCode() uint32

+ func (m *Eos) GetResetErrorCode() uint32

+ func (m *Eos) Reset()

+ func (m *Eos) String() string

+ type Eos_GrpcStatusCode struct

+ GrpcStatusCode uint32

+ type Eos_ResetErrorCode struct

+ ResetErrorCode uint32

+ type HttpMethod struct

+ Type isHttpMethod_Type

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

+ func (*HttpMethod) ProtoMessage()

+ func (*HttpMethod) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, ...)

+ func (m *HttpMethod) GetRegistered() HttpMethod_Registered

+ func (m *HttpMethod) GetType() isHttpMethod_Type

+ func (m *HttpMethod) GetUnregistered() string

+ func (m *HttpMethod) Reset()

+ func (m *HttpMethod) String() string

+ type HttpMethod_Registered int32

+ const HttpMethod_CONNECT

+ const HttpMethod_DELETE

+ const HttpMethod_GET

+ const HttpMethod_HEAD

+ const HttpMethod_OPTIONS

+ const HttpMethod_PATCH

+ const HttpMethod_POST

+ const HttpMethod_PUT

+ const HttpMethod_TRACE

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

+ func (x HttpMethod_Registered) String() string

+ type HttpMethod_Registered_ struct

+ Registered HttpMethod_Registered

+ type HttpMethod_Unregistered struct

+ Unregistered string

+ type ObserveRequest struct

+ Limit uint32

+ Match *ObserveRequest_Match

+ func (*ObserveRequest) Descriptor() ([]byte, []int)

+ func (*ObserveRequest) ProtoMessage()

+ func (m *ObserveRequest) GetLimit() uint32

+ func (m *ObserveRequest) GetMatch() *ObserveRequest_Match

+ func (m *ObserveRequest) Reset()

+ func (m *ObserveRequest) String() string

+ type ObserveRequest_Match struct

+ Match isObserveRequest_Match_Match

+ func (*ObserveRequest_Match) Descriptor() ([]byte, []int)

+ func (*ObserveRequest_Match) ProtoMessage()

+ func (*ObserveRequest_Match) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, ...)

+ func (m *ObserveRequest_Match) GetAll() *ObserveRequest_Match_Seq

+ func (m *ObserveRequest_Match) GetAny() *ObserveRequest_Match_Seq

+ func (m *ObserveRequest_Match) GetDestination() *ObserveRequest_Match_Tcp

+ func (m *ObserveRequest_Match) GetDestinationLabel() *ObserveRequest_Match_Label

+ func (m *ObserveRequest_Match) GetHttp() *ObserveRequest_Match_Http

+ func (m *ObserveRequest_Match) GetMatch() isObserveRequest_Match_Match

+ func (m *ObserveRequest_Match) GetNot() *ObserveRequest_Match

+ func (m *ObserveRequest_Match) GetSource() *ObserveRequest_Match_Tcp

+ func (m *ObserveRequest_Match) Reset()

+ func (m *ObserveRequest_Match) String() string

+ type ObserveRequest_Match_All struct

+ All *ObserveRequest_Match_Seq

+ type ObserveRequest_Match_Any struct

+ Any *ObserveRequest_Match_Seq

+ type ObserveRequest_Match_Destination struct

+ Destination *ObserveRequest_Match_Tcp

+ type ObserveRequest_Match_DestinationLabel struct

+ DestinationLabel *ObserveRequest_Match_Label

+ type ObserveRequest_Match_Http struct

+ Match isObserveRequest_Match_Http_Match

+ func (*ObserveRequest_Match_Http) Descriptor() ([]byte, []int)

+ func (*ObserveRequest_Match_Http) ProtoMessage()

+ func (*ObserveRequest_Match_Http) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, ...)

+ func (m *ObserveRequest_Match_Http) GetAuthority() *ObserveRequest_Match_Http_StringMatch

+ func (m *ObserveRequest_Match_Http) GetMatch() isObserveRequest_Match_Http_Match

+ func (m *ObserveRequest_Match_Http) GetMethod() *HttpMethod

+ func (m *ObserveRequest_Match_Http) GetPath() *ObserveRequest_Match_Http_StringMatch

+ func (m *ObserveRequest_Match_Http) GetScheme() *Scheme

+ func (m *ObserveRequest_Match_Http) Reset()

+ func (m *ObserveRequest_Match_Http) String() string

+ type ObserveRequest_Match_Http_ struct

+ Http *ObserveRequest_Match_Http

+ type ObserveRequest_Match_Http_Authority struct

+ Authority *ObserveRequest_Match_Http_StringMatch

+ type ObserveRequest_Match_Http_Method struct

+ Method *HttpMethod

+ type ObserveRequest_Match_Http_Path struct

+ Path *ObserveRequest_Match_Http_StringMatch

+ type ObserveRequest_Match_Http_Scheme struct

+ Scheme *Scheme

+ type ObserveRequest_Match_Http_StringMatch struct

+ Match isObserveRequest_Match_Http_StringMatch_Match

+ func (*ObserveRequest_Match_Http_StringMatch) Descriptor() ([]byte, []int)

+ func (*ObserveRequest_Match_Http_StringMatch) ProtoMessage()

+ func (*ObserveRequest_Match_Http_StringMatch) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, ...)

+ func (m *ObserveRequest_Match_Http_StringMatch) GetExact() string

+ func (m *ObserveRequest_Match_Http_StringMatch) GetMatch() isObserveRequest_Match_Http_StringMatch_Match

+ func (m *ObserveRequest_Match_Http_StringMatch) GetPrefix() string

+ func (m *ObserveRequest_Match_Http_StringMatch) Reset()

+ func (m *ObserveRequest_Match_Http_StringMatch) String() string

+ type ObserveRequest_Match_Http_StringMatch_Exact struct

+ Exact string

+ type ObserveRequest_Match_Http_StringMatch_Prefix struct

+ Prefix string

+ type ObserveRequest_Match_Label struct

+ Key string

+ Value string

+ func (*ObserveRequest_Match_Label) Descriptor() ([]byte, []int)

+ func (*ObserveRequest_Match_Label) ProtoMessage()

+ func (m *ObserveRequest_Match_Label) GetKey() string

+ func (m *ObserveRequest_Match_Label) GetValue() string

+ func (m *ObserveRequest_Match_Label) Reset()

+ func (m *ObserveRequest_Match_Label) String() string

+ type ObserveRequest_Match_Not struct

+ Not *ObserveRequest_Match

+ type ObserveRequest_Match_Seq struct

+ Matches []*ObserveRequest_Match

+ func (*ObserveRequest_Match_Seq) Descriptor() ([]byte, []int)

+ func (*ObserveRequest_Match_Seq) ProtoMessage()

+ func (m *ObserveRequest_Match_Seq) GetMatches() []*ObserveRequest_Match

+ func (m *ObserveRequest_Match_Seq) Reset()

+ func (m *ObserveRequest_Match_Seq) String() string

+ type ObserveRequest_Match_Source struct

+ Source *ObserveRequest_Match_Tcp

+ type ObserveRequest_Match_Tcp struct

+ Match isObserveRequest_Match_Tcp_Match

+ func (*ObserveRequest_Match_Tcp) Descriptor() ([]byte, []int)

+ func (*ObserveRequest_Match_Tcp) ProtoMessage()

+ func (*ObserveRequest_Match_Tcp) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, ...)

+ func (m *ObserveRequest_Match_Tcp) GetMatch() isObserveRequest_Match_Tcp_Match

+ func (m *ObserveRequest_Match_Tcp) GetNetmask() *ObserveRequest_Match_Tcp_Netmask

+ func (m *ObserveRequest_Match_Tcp) GetPorts() *ObserveRequest_Match_Tcp_PortRange

+ func (m *ObserveRequest_Match_Tcp) Reset()

+ func (m *ObserveRequest_Match_Tcp) String() string

+ type ObserveRequest_Match_Tcp_Netmask struct

+ Ip *io_linkerd_proxy_net.IPAddress

+ Mask uint32

+ func (*ObserveRequest_Match_Tcp_Netmask) Descriptor() ([]byte, []int)

+ func (*ObserveRequest_Match_Tcp_Netmask) ProtoMessage()

+ func (m *ObserveRequest_Match_Tcp_Netmask) GetIp() *io_linkerd_proxy_net.IPAddress

+ func (m *ObserveRequest_Match_Tcp_Netmask) GetMask() uint32

+ func (m *ObserveRequest_Match_Tcp_Netmask) Reset()

+ func (m *ObserveRequest_Match_Tcp_Netmask) String() string

+ type ObserveRequest_Match_Tcp_Netmask_ struct

+ Netmask *ObserveRequest_Match_Tcp_Netmask

+ type ObserveRequest_Match_Tcp_PortRange struct

+ Max uint32

+ Min uint32

+ func (*ObserveRequest_Match_Tcp_PortRange) Descriptor() ([]byte, []int)

+ func (*ObserveRequest_Match_Tcp_PortRange) ProtoMessage()

+ func (m *ObserveRequest_Match_Tcp_PortRange) GetMax() uint32

+ func (m *ObserveRequest_Match_Tcp_PortRange) GetMin() uint32

+ func (m *ObserveRequest_Match_Tcp_PortRange) Reset()

+ func (m *ObserveRequest_Match_Tcp_PortRange) String() string

+ type ObserveRequest_Match_Tcp_Ports struct

+ Ports *ObserveRequest_Match_Tcp_PortRange

+ type Scheme struct

+ Type isScheme_Type

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

+ func (*Scheme) ProtoMessage()

+ func (*Scheme) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, ...)

+ func (m *Scheme) GetRegistered() Scheme_Registered

+ func (m *Scheme) GetType() isScheme_Type

+ func (m *Scheme) GetUnregistered() string

+ func (m *Scheme) Reset()

+ func (m *Scheme) String() string

+ type Scheme_Registered int32

+ const Scheme_HTTP

+ const Scheme_HTTPS

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

+ func (x Scheme_Registered) String() string

+ type Scheme_Registered_ struct

+ Registered Scheme_Registered

+ type Scheme_Unregistered struct

+ Unregistered string

+ type TapClient interface

+ Observe func(ctx context.Context, in *ObserveRequest, opts ...grpc.CallOption) (Tap_ObserveClient, error)

+ func NewTapClient(cc *grpc.ClientConn) TapClient

+ type TapEvent struct

+ Destination *io_linkerd_proxy_net.TcpAddress

+ DestinationMeta *TapEvent_EndpointMeta

+ Event isTapEvent_Event

+ ProxyDirection TapEvent_ProxyDirection

+ Source *io_linkerd_proxy_net.TcpAddress

+ SourceMeta *TapEvent_EndpointMeta

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

+ func (*TapEvent) ProtoMessage()

+ func (*TapEvent) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, ...)

+ func (m *TapEvent) GetDestination() *io_linkerd_proxy_net.TcpAddress

+ func (m *TapEvent) GetDestinationMeta() *TapEvent_EndpointMeta

+ func (m *TapEvent) GetEvent() isTapEvent_Event

+ func (m *TapEvent) GetHttp() *TapEvent_Http

+ func (m *TapEvent) GetProxyDirection() TapEvent_ProxyDirection

+ func (m *TapEvent) GetSource() *io_linkerd_proxy_net.TcpAddress

+ func (m *TapEvent) GetSourceMeta() *TapEvent_EndpointMeta

+ func (m *TapEvent) Reset()

+ func (m *TapEvent) String() string

+ type TapEvent_EndpointMeta struct

+ Labels map[string]string

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

+ func (*TapEvent_EndpointMeta) ProtoMessage()

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

+ func (m *TapEvent_EndpointMeta) Reset()

+ func (m *TapEvent_EndpointMeta) String() string

+ type TapEvent_Http struct

+ Event isTapEvent_Http_Event

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

+ func (*TapEvent_Http) ProtoMessage()

+ func (*TapEvent_Http) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, ...)

+ func (m *TapEvent_Http) GetEvent() isTapEvent_Http_Event

+ func (m *TapEvent_Http) GetRequestInit() *TapEvent_Http_RequestInit

+ func (m *TapEvent_Http) GetResponseEnd() *TapEvent_Http_ResponseEnd

+ func (m *TapEvent_Http) GetResponseInit() *TapEvent_Http_ResponseInit

+ func (m *TapEvent_Http) Reset()

+ func (m *TapEvent_Http) String() string

+ type TapEvent_Http_ struct

+ Http *TapEvent_Http

+ type TapEvent_Http_RequestInit struct

+ Authority string

+ Id *TapEvent_Http_StreamId

+ Method *HttpMethod

+ Path string

+ Scheme *Scheme

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

+ func (*TapEvent_Http_RequestInit) ProtoMessage()

+ func (m *TapEvent_Http_RequestInit) GetAuthority() string

+ func (m *TapEvent_Http_RequestInit) GetId() *TapEvent_Http_StreamId

+ func (m *TapEvent_Http_RequestInit) GetMethod() *HttpMethod

+ func (m *TapEvent_Http_RequestInit) GetPath() string

+ func (m *TapEvent_Http_RequestInit) GetScheme() *Scheme

+ func (m *TapEvent_Http_RequestInit) Reset()

+ func (m *TapEvent_Http_RequestInit) String() string

+ type TapEvent_Http_RequestInit_ struct

+ RequestInit *TapEvent_Http_RequestInit

+ type TapEvent_Http_ResponseEnd struct

+ Eos *Eos

+ Id *TapEvent_Http_StreamId

+ ResponseBytes uint64

+ SinceRequestInit *google_protobuf.Duration

+ SinceResponseInit *google_protobuf.Duration

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

+ func (*TapEvent_Http_ResponseEnd) ProtoMessage()

+ func (m *TapEvent_Http_ResponseEnd) GetEos() *Eos

+ func (m *TapEvent_Http_ResponseEnd) GetId() *TapEvent_Http_StreamId

+ func (m *TapEvent_Http_ResponseEnd) GetResponseBytes() uint64

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

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

+ func (m *TapEvent_Http_ResponseEnd) Reset()

+ func (m *TapEvent_Http_ResponseEnd) String() string

+ type TapEvent_Http_ResponseEnd_ struct

+ ResponseEnd *TapEvent_Http_ResponseEnd

+ type TapEvent_Http_ResponseInit struct

+ HttpStatus uint32

+ Id *TapEvent_Http_StreamId

+ SinceRequestInit *google_protobuf.Duration

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

+ func (*TapEvent_Http_ResponseInit) ProtoMessage()

+ func (m *TapEvent_Http_ResponseInit) GetHttpStatus() uint32

+ func (m *TapEvent_Http_ResponseInit) GetId() *TapEvent_Http_StreamId

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

+ func (m *TapEvent_Http_ResponseInit) Reset()

+ func (m *TapEvent_Http_ResponseInit) String() string

+ type TapEvent_Http_ResponseInit_ struct

+ ResponseInit *TapEvent_Http_ResponseInit

+ type TapEvent_Http_StreamId struct

+ Base uint32

+ Stream uint64

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

+ func (*TapEvent_Http_StreamId) ProtoMessage()

+ func (m *TapEvent_Http_StreamId) GetBase() uint32

+ func (m *TapEvent_Http_StreamId) GetStream() uint64

+ func (m *TapEvent_Http_StreamId) Reset()

+ func (m *TapEvent_Http_StreamId) String() string

+ type TapEvent_ProxyDirection int32

+ const TapEvent_INBOUND

+ const TapEvent_OUTBOUND

+ const TapEvent_UNKNOWN

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

+ func (x TapEvent_ProxyDirection) String() string

+ type TapServer interface

+ Observe func(*ObserveRequest, Tap_ObserveServer) error

+ type Tap_ObserveClient interface

+ Recv func() (*TapEvent, error)

+ type Tap_ObserveServer interface

+ Send func(*TapEvent) error

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