tap

package
v0.15.0 Latest Latest
Warning

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

 Go to latest Published: Nov 21, 2024 License: Apache-2.0 Imports: 11 Imported by: 25

Documentation

Index

Constants

View Source 
const (
	Tap_Observe_FullMethodName = "/io.linkerd.proxy.tap.Tap/Observe"
)

Variables

View Source 
var (
	TapEvent_ProxyDirection_name = map[int32]string{
		0: "UNKNOWN",
		1: "INBOUND",
		2: "OUTBOUND",
	}
	TapEvent_ProxyDirection_value = map[string]int32{
		"UNKNOWN":  0,
		"INBOUND":  1,
		"OUTBOUND": 2,
	}
)

Enum value maps for TapEvent_ProxyDirection.

View Source 
var File_tap_proto protoreflect.FileDescriptor
View Source 
var Tap_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "io.linkerd.proxy.tap.Tap",
	HandlerType: (*TapServer)(nil),
	Methods:     []grpc.MethodDesc{},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "Observe",
			Handler:       _Tap_Observe_Handler,
			ServerStreams: true,
		},
	},
	Metadata: "tap.proto",
}

Tap_ServiceDesc is the grpc.ServiceDesc for Tap service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

Functions

func RegisterTapServer 

func RegisterTapServer(s grpc.ServiceRegistrar, srv TapServer)

Types

type Eos 

type Eos struct {

	// Types that are assignable to End:
	//
	//	*Eos_GrpcStatusCode
	//	*Eos_ResetErrorCode
	End isEos_End `protobuf_oneof:"end"`
	// contains filtered or unexported fields
}

func (*Eos) Descriptor deprecated 

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

Deprecated: Use Eos.ProtoReflect.Descriptor instead.

func (*Eos) GetEnd 

func (m *Eos) GetEnd() isEos_End

func (*Eos) GetGrpcStatusCode 

func (x *Eos) GetGrpcStatusCode() uint32

func (*Eos) GetResetErrorCode 

func (x *Eos) GetResetErrorCode() uint32

func (*Eos) ProtoMessage 

func (*Eos) ProtoMessage()

func (*Eos) ProtoReflect added in v0.1.13 

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

func (*Eos) Reset 

func (x *Eos) Reset()

func (*Eos) String 

func (x *Eos) String() string

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 ObserveRequest 

type ObserveRequest struct {

	// Limits the number of event keys that will be returned by this tap.
	Limit uint32 `protobuf:"varint,1,opt,name=limit,proto3" json:"limit,omitempty"`
	// Encodes request-matching logic.
	Match *ObserveRequest_Match `protobuf:"bytes,2,opt,name=match,proto3" json:"match,omitempty"`
	// Conditionally extracts components from requests and responses to include
	// in tap events
	Extract *ObserveRequest_Extract `protobuf:"bytes,3,opt,name=extract,proto3" json:"extract,omitempty"`
	// contains filtered or unexported fields
}

func (*ObserveRequest) Descriptor deprecated 

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

Deprecated: Use ObserveRequest.ProtoReflect.Descriptor instead.

func (*ObserveRequest) GetExtract added in v0.1.10 

func (x *ObserveRequest) GetExtract() *ObserveRequest_Extract

func (*ObserveRequest) GetLimit 

func (x *ObserveRequest) GetLimit() uint32

func (*ObserveRequest) GetMatch 

func (x *ObserveRequest) GetMatch() *ObserveRequest_Match

func (*ObserveRequest) ProtoMessage 

func (*ObserveRequest) ProtoMessage()

func (*ObserveRequest) ProtoReflect added in v0.1.13 

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

func (*ObserveRequest) Reset 

func (x *ObserveRequest) Reset()

func (*ObserveRequest) String 

func (x *ObserveRequest) String() string

type ObserveRequest_Extract added in v0.1.10 

type ObserveRequest_Extract struct {

	// Types that are assignable to Extract:
	//
	//	*ObserveRequest_Extract_Http_
	Extract isObserveRequest_Extract_Extract `protobuf_oneof:"extract"`
	// contains filtered or unexported fields
}

func (*ObserveRequest_Extract) Descriptor deprecated added in v0.1.10 

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

Deprecated: Use ObserveRequest_Extract.ProtoReflect.Descriptor instead.

func (*ObserveRequest_Extract) GetExtract added in v0.1.10 

func (m *ObserveRequest_Extract) GetExtract() isObserveRequest_Extract_Extract

func (*ObserveRequest_Extract) GetHttp added in v0.1.10 

func (x *ObserveRequest_Extract) GetHttp() *ObserveRequest_Extract_Http

func (*ObserveRequest_Extract) ProtoMessage added in v0.1.10 

func (*ObserveRequest_Extract) ProtoMessage()

func (*ObserveRequest_Extract) ProtoReflect added in v0.1.13 

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

func (*ObserveRequest_Extract) Reset added in v0.1.10 

func (x *ObserveRequest_Extract) Reset()

func (*ObserveRequest_Extract) String added in v0.1.10 

func (x *ObserveRequest_Extract) String() string

type ObserveRequest_Extract_Http added in v0.1.10 

type ObserveRequest_Extract_Http struct {

	// Types that are assignable to Extract:
	//
	//	*ObserveRequest_Extract_Http_Headers_
	Extract isObserveRequest_Extract_Http_Extract `protobuf_oneof:"extract"`
	// contains filtered or unexported fields
}

func (*ObserveRequest_Extract_Http) Descriptor deprecated added in v0.1.10 

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

Deprecated: Use ObserveRequest_Extract_Http.ProtoReflect.Descriptor instead.

func (*ObserveRequest_Extract_Http) GetExtract added in v0.1.10 

func (m *ObserveRequest_Extract_Http) GetExtract() isObserveRequest_Extract_Http_Extract

func (*ObserveRequest_Extract_Http) GetHeaders added in v0.1.10 

func (x *ObserveRequest_Extract_Http) GetHeaders() *ObserveRequest_Extract_Http_Headers

func (*ObserveRequest_Extract_Http) ProtoMessage added in v0.1.10 

func (*ObserveRequest_Extract_Http) ProtoMessage()

func (*ObserveRequest_Extract_Http) ProtoReflect added in v0.1.13 

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

func (*ObserveRequest_Extract_Http) Reset added in v0.1.10 

func (x *ObserveRequest_Extract_Http) Reset()

func (*ObserveRequest_Extract_Http) String added in v0.1.10 

func (x *ObserveRequest_Extract_Http) String() string

type ObserveRequest_Extract_Http_ added in v0.1.10 

type ObserveRequest_Extract_Http_ struct {
	Http *ObserveRequest_Extract_Http `protobuf:"bytes,1,opt,name=http,proto3,oneof"`
}

type ObserveRequest_Extract_Http_Headers added in v0.1.10 

type ObserveRequest_Extract_Http_Headers struct {
	// contains filtered or unexported fields
}

func (*ObserveRequest_Extract_Http_Headers) Descriptor deprecated added in v0.1.10 

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

Deprecated: Use ObserveRequest_Extract_Http_Headers.ProtoReflect.Descriptor instead.

func (*ObserveRequest_Extract_Http_Headers) ProtoMessage added in v0.1.10 

func (*ObserveRequest_Extract_Http_Headers) ProtoMessage()

func (*ObserveRequest_Extract_Http_Headers) ProtoReflect added in v0.1.13 

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

func (*ObserveRequest_Extract_Http_Headers) Reset added in v0.1.10 

func (x *ObserveRequest_Extract_Http_Headers) Reset()

func (*ObserveRequest_Extract_Http_Headers) String added in v0.1.10 

func (x *ObserveRequest_Extract_Http_Headers) String() string

type ObserveRequest_Extract_Http_Headers_ added in v0.1.10 

type ObserveRequest_Extract_Http_Headers_ struct {
	Headers *ObserveRequest_Extract_Http_Headers `protobuf:"bytes,1,opt,name=headers,proto3,oneof"`
}

type ObserveRequest_Match 

type ObserveRequest_Match struct {

	// Types that are assignable to Match:
	//
	//	*ObserveRequest_Match_All
	//	*ObserveRequest_Match_Any
	//	*ObserveRequest_Match_Not
	//	*ObserveRequest_Match_Source
	//	*ObserveRequest_Match_Destination
	//	*ObserveRequest_Match_Http_
	//	*ObserveRequest_Match_DestinationLabel
	//	*ObserveRequest_Match_RouteLabel
	Match isObserveRequest_Match_Match `protobuf_oneof:"match"`
	// contains filtered or unexported fields
}

func (*ObserveRequest_Match) Descriptor deprecated 

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

Deprecated: Use ObserveRequest_Match.ProtoReflect.Descriptor instead.

func (*ObserveRequest_Match) GetAll 

func (x *ObserveRequest_Match) GetAll() *ObserveRequest_Match_Seq

func (*ObserveRequest_Match) GetAny 

func (x *ObserveRequest_Match) GetAny() *ObserveRequest_Match_Seq

func (*ObserveRequest_Match) GetDestination 

func (x *ObserveRequest_Match) GetDestination() *ObserveRequest_Match_Tcp

func (*ObserveRequest_Match) GetDestinationLabel 

func (x *ObserveRequest_Match) GetDestinationLabel() *ObserveRequest_Match_Label

func (*ObserveRequest_Match) GetHttp 

func (x *ObserveRequest_Match) GetHttp() *ObserveRequest_Match_Http

func (*ObserveRequest_Match) GetMatch 

func (m *ObserveRequest_Match) GetMatch() isObserveRequest_Match_Match

func (*ObserveRequest_Match) GetNot 

func (x *ObserveRequest_Match) GetNot() *ObserveRequest_Match

func (*ObserveRequest_Match) GetRouteLabel added in v0.1.4 

func (x *ObserveRequest_Match) GetRouteLabel() *ObserveRequest_Match_Label

func (*ObserveRequest_Match) GetSource 

func (x *ObserveRequest_Match) GetSource() *ObserveRequest_Match_Tcp

func (*ObserveRequest_Match) ProtoMessage 

func (*ObserveRequest_Match) ProtoMessage()

func (*ObserveRequest_Match) ProtoReflect added in v0.1.13 

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

func (*ObserveRequest_Match) Reset 

func (x *ObserveRequest_Match) Reset()

func (*ObserveRequest_Match) String 

func (x *ObserveRequest_Match) String() string

type ObserveRequest_Match_All 

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

type ObserveRequest_Match_Any 

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

type ObserveRequest_Match_Destination 

type ObserveRequest_Match_Destination struct {
	Destination *ObserveRequest_Match_Tcp `protobuf:"bytes,5,opt,name=destination,proto3,oneof"`
}

type ObserveRequest_Match_DestinationLabel 

type ObserveRequest_Match_DestinationLabel struct {
	DestinationLabel *ObserveRequest_Match_Label `protobuf:"bytes,7,opt,name=destination_label,json=destinationLabel,proto3,oneof"`
}

type ObserveRequest_Match_Http 

type ObserveRequest_Match_Http struct {

	// Types that are assignable to Match:
	//
	//	*ObserveRequest_Match_Http_Scheme
	//	*ObserveRequest_Match_Http_Method
	//	*ObserveRequest_Match_Http_Authority
	//	*ObserveRequest_Match_Http_Path
	Match isObserveRequest_Match_Http_Match `protobuf_oneof:"match"`
	// contains filtered or unexported fields
}

func (*ObserveRequest_Match_Http) Descriptor deprecated 

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

Deprecated: Use ObserveRequest_Match_Http.ProtoReflect.Descriptor instead.

func (*ObserveRequest_Match_Http) GetAuthority 

func (x *ObserveRequest_Match_Http) GetAuthority() *ObserveRequest_Match_Http_StringMatch

func (*ObserveRequest_Match_Http) GetMatch 

func (m *ObserveRequest_Match_Http) GetMatch() isObserveRequest_Match_Http_Match

func (*ObserveRequest_Match_Http) GetMethod 

func (x *ObserveRequest_Match_Http) GetMethod() *http_types.HttpMethod

func (*ObserveRequest_Match_Http) GetPath 

func (x *ObserveRequest_Match_Http) GetPath() *ObserveRequest_Match_Http_StringMatch

func (*ObserveRequest_Match_Http) GetScheme 

func (x *ObserveRequest_Match_Http) GetScheme() *http_types.Scheme

func (*ObserveRequest_Match_Http) ProtoMessage 

func (*ObserveRequest_Match_Http) ProtoMessage()

func (*ObserveRequest_Match_Http) ProtoReflect added in v0.1.13 

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

func (*ObserveRequest_Match_Http) Reset 

func (x *ObserveRequest_Match_Http) Reset()

func (*ObserveRequest_Match_Http) String 

func (x *ObserveRequest_Match_Http) String() string

type ObserveRequest_Match_Http_ 

type ObserveRequest_Match_Http_ struct {
	Http *ObserveRequest_Match_Http `protobuf:"bytes,6,opt,name=http,proto3,oneof"`
}

type ObserveRequest_Match_Http_Authority 

type ObserveRequest_Match_Http_Authority struct {
	Authority *ObserveRequest_Match_Http_StringMatch `protobuf:"bytes,2,opt,name=authority,proto3,oneof"`
}

type ObserveRequest_Match_Http_Method 

type ObserveRequest_Match_Http_Method struct {
	Method *http_types.HttpMethod `protobuf:"bytes,3,opt,name=method,proto3,oneof"`
}

type ObserveRequest_Match_Http_Path 

type ObserveRequest_Match_Http_Path struct {
	Path *ObserveRequest_Match_Http_StringMatch `protobuf:"bytes,4,opt,name=path,proto3,oneof"` // TODO Header        header    = 4;
}

type ObserveRequest_Match_Http_Scheme 

type ObserveRequest_Match_Http_Scheme struct {
	Scheme *http_types.Scheme `protobuf:"bytes,1,opt,name=scheme,proto3,oneof"`
}

type ObserveRequest_Match_Http_StringMatch 

type ObserveRequest_Match_Http_StringMatch struct {

	// Types that are assignable to Match:
	//
	//	*ObserveRequest_Match_Http_StringMatch_Exact
	//	*ObserveRequest_Match_Http_StringMatch_Prefix
	Match isObserveRequest_Match_Http_StringMatch_Match `protobuf_oneof:"match"`
	// contains filtered or unexported fields
}

func (*ObserveRequest_Match_Http_StringMatch) Descriptor deprecated 

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

Deprecated: Use ObserveRequest_Match_Http_StringMatch.ProtoReflect.Descriptor instead.

func (*ObserveRequest_Match_Http_StringMatch) GetExact 

func (x *ObserveRequest_Match_Http_StringMatch) GetExact() string

func (*ObserveRequest_Match_Http_StringMatch) GetMatch 

func (m *ObserveRequest_Match_Http_StringMatch) GetMatch() isObserveRequest_Match_Http_StringMatch_Match

func (*ObserveRequest_Match_Http_StringMatch) GetPrefix 

func (x *ObserveRequest_Match_Http_StringMatch) GetPrefix() string

func (*ObserveRequest_Match_Http_StringMatch) ProtoMessage 

func (*ObserveRequest_Match_Http_StringMatch) ProtoMessage()

func (*ObserveRequest_Match_Http_StringMatch) ProtoReflect added in v0.1.13 

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

func (*ObserveRequest_Match_Http_StringMatch) Reset 

func (x *ObserveRequest_Match_Http_StringMatch) Reset()

func (*ObserveRequest_Match_Http_StringMatch) String 

func (x *ObserveRequest_Match_Http_StringMatch) String() string

type ObserveRequest_Match_Http_StringMatch_Exact 

type ObserveRequest_Match_Http_StringMatch_Exact struct {
	Exact string `protobuf:"bytes,1,opt,name=exact,proto3,oneof"`
}

type ObserveRequest_Match_Http_StringMatch_Prefix 

type ObserveRequest_Match_Http_StringMatch_Prefix struct {
	Prefix string `protobuf:"bytes,2,opt,name=prefix,proto3,oneof"`
}

type ObserveRequest_Match_Label 

type ObserveRequest_Match_Label struct {
	Key   string `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	Value string `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
	// contains filtered or unexported fields
}

func (*ObserveRequest_Match_Label) Descriptor deprecated 

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

Deprecated: Use ObserveRequest_Match_Label.ProtoReflect.Descriptor instead.

func (*ObserveRequest_Match_Label) GetKey 

func (x *ObserveRequest_Match_Label) GetKey() string

func (*ObserveRequest_Match_Label) GetValue 

func (x *ObserveRequest_Match_Label) GetValue() string

func (*ObserveRequest_Match_Label) ProtoMessage 

func (*ObserveRequest_Match_Label) ProtoMessage()

func (*ObserveRequest_Match_Label) ProtoReflect added in v0.1.13 

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

func (*ObserveRequest_Match_Label) Reset 

func (x *ObserveRequest_Match_Label) Reset()

func (*ObserveRequest_Match_Label) String 

func (x *ObserveRequest_Match_Label) String() string

type ObserveRequest_Match_Not 

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

type ObserveRequest_Match_RouteLabel added in v0.1.4 

type ObserveRequest_Match_RouteLabel struct {
	RouteLabel *ObserveRequest_Match_Label `protobuf:"bytes,8,opt,name=route_label,json=routeLabel,proto3,oneof"`
}

type ObserveRequest_Match_Seq 

type ObserveRequest_Match_Seq struct {
	Matches []*ObserveRequest_Match `protobuf:"bytes,1,rep,name=matches,proto3" json:"matches,omitempty"`
	// contains filtered or unexported fields
}

func (*ObserveRequest_Match_Seq) Descriptor deprecated 

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

Deprecated: Use ObserveRequest_Match_Seq.ProtoReflect.Descriptor instead.

func (*ObserveRequest_Match_Seq) GetMatches 

func (x *ObserveRequest_Match_Seq) GetMatches() []*ObserveRequest_Match

func (*ObserveRequest_Match_Seq) ProtoMessage 

func (*ObserveRequest_Match_Seq) ProtoMessage()

func (*ObserveRequest_Match_Seq) ProtoReflect added in v0.1.13 

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

func (*ObserveRequest_Match_Seq) Reset 

func (x *ObserveRequest_Match_Seq) Reset()

func (*ObserveRequest_Match_Seq) String 

func (x *ObserveRequest_Match_Seq) String() string

type ObserveRequest_Match_Source 

type ObserveRequest_Match_Source struct {
	Source *ObserveRequest_Match_Tcp `protobuf:"bytes,4,opt,name=source,proto3,oneof"`
}

type ObserveRequest_Match_Tcp 

type ObserveRequest_Match_Tcp struct {

	// Types that are assignable to Match:
	//
	//	*ObserveRequest_Match_Tcp_Netmask_
	//	*ObserveRequest_Match_Tcp_Ports
	Match isObserveRequest_Match_Tcp_Match `protobuf_oneof:"match"`
	// contains filtered or unexported fields
}

func (*ObserveRequest_Match_Tcp) Descriptor deprecated 

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

Deprecated: Use ObserveRequest_Match_Tcp.ProtoReflect.Descriptor instead.

func (*ObserveRequest_Match_Tcp) GetMatch 

func (m *ObserveRequest_Match_Tcp) GetMatch() isObserveRequest_Match_Tcp_Match

func (*ObserveRequest_Match_Tcp) GetNetmask 

func (x *ObserveRequest_Match_Tcp) GetNetmask() *ObserveRequest_Match_Tcp_Netmask

func (*ObserveRequest_Match_Tcp) GetPorts 

func (x *ObserveRequest_Match_Tcp) GetPorts() *ObserveRequest_Match_Tcp_PortRange

func (*ObserveRequest_Match_Tcp) ProtoMessage 

func (*ObserveRequest_Match_Tcp) ProtoMessage()

func (*ObserveRequest_Match_Tcp) ProtoReflect added in v0.1.13 

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

func (*ObserveRequest_Match_Tcp) Reset 

func (x *ObserveRequest_Match_Tcp) Reset()

func (*ObserveRequest_Match_Tcp) String 

func (x *ObserveRequest_Match_Tcp) String() string

type ObserveRequest_Match_Tcp_Netmask 

type ObserveRequest_Match_Tcp_Netmask struct {
	Ip   *net.IPAddress `protobuf:"bytes,1,opt,name=ip,proto3" json:"ip,omitempty"`
	Mask uint32         `protobuf:"varint,2,opt,name=mask,proto3" json:"mask,omitempty"`
	// contains filtered or unexported fields
}

func (*ObserveRequest_Match_Tcp_Netmask) Descriptor deprecated 

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

Deprecated: Use ObserveRequest_Match_Tcp_Netmask.ProtoReflect.Descriptor instead.

func (*ObserveRequest_Match_Tcp_Netmask) GetIp 

func (x *ObserveRequest_Match_Tcp_Netmask) GetIp() *net.IPAddress

func (*ObserveRequest_Match_Tcp_Netmask) GetMask 

func (x *ObserveRequest_Match_Tcp_Netmask) GetMask() uint32

func (*ObserveRequest_Match_Tcp_Netmask) ProtoMessage 

func (*ObserveRequest_Match_Tcp_Netmask) ProtoMessage()

func (*ObserveRequest_Match_Tcp_Netmask) ProtoReflect added in v0.1.13 

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

func (*ObserveRequest_Match_Tcp_Netmask) Reset 

func (x *ObserveRequest_Match_Tcp_Netmask) Reset()

func (*ObserveRequest_Match_Tcp_Netmask) String 

func (x *ObserveRequest_Match_Tcp_Netmask) String() string

type ObserveRequest_Match_Tcp_Netmask_ 

type ObserveRequest_Match_Tcp_Netmask_ struct {
	Netmask *ObserveRequest_Match_Tcp_Netmask `protobuf:"bytes,1,opt,name=netmask,proto3,oneof"`
}

type ObserveRequest_Match_Tcp_PortRange 

type ObserveRequest_Match_Tcp_PortRange struct {

	// Minimum matching port value (inclusive), if specified.
	Min uint32 `protobuf:"varint,1,opt,name=min,proto3" json:"min,omitempty"`
	// Maximum matching port value (inclusive), if specified.
	Max uint32 `protobuf:"varint,2,opt,name=max,proto3" json:"max,omitempty"`
	// contains filtered or unexported fields
}

If either a minimum or maximum is not specified, the range is considered to be over a discrete value.

func (*ObserveRequest_Match_Tcp_PortRange) Descriptor deprecated 

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

Deprecated: Use ObserveRequest_Match_Tcp_PortRange.ProtoReflect.Descriptor instead.

func (*ObserveRequest_Match_Tcp_PortRange) GetMax 

func (x *ObserveRequest_Match_Tcp_PortRange) GetMax() uint32

func (*ObserveRequest_Match_Tcp_PortRange) GetMin 

func (x *ObserveRequest_Match_Tcp_PortRange) GetMin() uint32

func (*ObserveRequest_Match_Tcp_PortRange) ProtoMessage 

func (*ObserveRequest_Match_Tcp_PortRange) ProtoMessage()

func (*ObserveRequest_Match_Tcp_PortRange) ProtoReflect added in v0.1.13 

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

func (*ObserveRequest_Match_Tcp_PortRange) Reset 

func (x *ObserveRequest_Match_Tcp_PortRange) Reset()

func (*ObserveRequest_Match_Tcp_PortRange) String 

func (x *ObserveRequest_Match_Tcp_PortRange) String() string

type ObserveRequest_Match_Tcp_Ports 

type ObserveRequest_Match_Tcp_Ports struct {
	Ports *ObserveRequest_Match_Tcp_PortRange `protobuf:"bytes,3,opt,name=ports,proto3,oneof"`
}

type TapClient 

type TapClient interface {
	Observe(ctx context.Context, in *ObserveRequest, opts ...grpc.CallOption) (grpc.ServerStreamingClient[TapEvent], error)
}

TapClient is the client API for Tap service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

A service exposed by proxy instances to setup

func NewTapClient 

func NewTapClient(cc grpc.ClientConnInterface) TapClient

type TapEvent 

type TapEvent struct {
	Source          *net.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"`
	RouteMeta       *TapEvent_RouteMeta     `protobuf:"bytes,7,opt,name=route_meta,json=routeMeta,proto3" json:"route_meta,omitempty"`
	Destination     *net.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 `` /* 154-byte string literal not displayed */
	// Types that are assignable to Event:
	//
	//	*TapEvent_Http_
	Event isTapEvent_Event `protobuf_oneof:"event"`
	// contains filtered or unexported fields
}

func (*TapEvent) Descriptor deprecated 

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

Deprecated: Use TapEvent.ProtoReflect.Descriptor instead.

func (*TapEvent) GetDestination 

func (x *TapEvent) GetDestination() *net.TcpAddress

func (*TapEvent) GetDestinationMeta 

func (x *TapEvent) GetDestinationMeta() *TapEvent_EndpointMeta

func (*TapEvent) GetEvent 

func (m *TapEvent) GetEvent() isTapEvent_Event

func (*TapEvent) GetHttp 

func (x *TapEvent) GetHttp() *TapEvent_Http

func (*TapEvent) GetProxyDirection 

func (x *TapEvent) GetProxyDirection() TapEvent_ProxyDirection

func (*TapEvent) GetRouteMeta added in v0.1.4 

func (x *TapEvent) GetRouteMeta() *TapEvent_RouteMeta

func (*TapEvent) GetSource 

func (x *TapEvent) GetSource() *net.TcpAddress

func (*TapEvent) GetSourceMeta 

func (x *TapEvent) GetSourceMeta() *TapEvent_EndpointMeta

func (*TapEvent) ProtoMessage 

func (*TapEvent) ProtoMessage()

func (*TapEvent) ProtoReflect added in v0.1.13 

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

func (*TapEvent) Reset 

func (x *TapEvent) Reset()

func (*TapEvent) String 

func (x *TapEvent) String() string

type TapEvent_EndpointMeta 

type TapEvent_EndpointMeta struct {
	Labels map[string]string `` /* 153-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*TapEvent_EndpointMeta) Descriptor deprecated 

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

Deprecated: Use TapEvent_EndpointMeta.ProtoReflect.Descriptor instead.

func (*TapEvent_EndpointMeta) GetLabels 

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

func (*TapEvent_EndpointMeta) ProtoMessage 

func (*TapEvent_EndpointMeta) ProtoMessage()

func (*TapEvent_EndpointMeta) ProtoReflect added in v0.1.13 

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

func (*TapEvent_EndpointMeta) Reset 

func (x *TapEvent_EndpointMeta) Reset()

func (*TapEvent_EndpointMeta) String 

func (x *TapEvent_EndpointMeta) String() string

type TapEvent_Http 

type TapEvent_Http struct {

	// Types that are assignable to Event:
	//
	//	*TapEvent_Http_RequestInit_
	//	*TapEvent_Http_ResponseInit_
	//	*TapEvent_Http_ResponseEnd_
	Event isTapEvent_Http_Event `protobuf_oneof:"event"`
	// contains filtered or unexported fields
}

func (*TapEvent_Http) Descriptor deprecated 

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

Deprecated: Use TapEvent_Http.ProtoReflect.Descriptor instead.

func (*TapEvent_Http) GetEvent 

func (m *TapEvent_Http) GetEvent() isTapEvent_Http_Event

func (*TapEvent_Http) GetRequestInit 

func (x *TapEvent_Http) GetRequestInit() *TapEvent_Http_RequestInit

func (*TapEvent_Http) GetResponseEnd 

func (x *TapEvent_Http) GetResponseEnd() *TapEvent_Http_ResponseEnd

func (*TapEvent_Http) GetResponseInit 

func (x *TapEvent_Http) GetResponseInit() *TapEvent_Http_ResponseInit

func (*TapEvent_Http) ProtoMessage 

func (*TapEvent_Http) ProtoMessage()

func (*TapEvent_Http) ProtoReflect added in v0.1.13 

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

func (*TapEvent_Http) Reset 

func (x *TapEvent_Http) Reset()

func (*TapEvent_Http) String 

func (x *TapEvent_Http) String() string

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    *http_types.HttpMethod  `protobuf:"bytes,2,opt,name=method,proto3" json:"method,omitempty"`
	Scheme    *http_types.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"`
	Headers   *http_types.Headers     `protobuf:"bytes,6,opt,name=headers,proto3" json:"headers,omitempty"`
	// contains filtered or unexported fields
}

func (*TapEvent_Http_RequestInit) Descriptor deprecated 

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

Deprecated: Use TapEvent_Http_RequestInit.ProtoReflect.Descriptor instead.

func (*TapEvent_Http_RequestInit) GetAuthority 

func (x *TapEvent_Http_RequestInit) GetAuthority() string

func (*TapEvent_Http_RequestInit) GetHeaders added in v0.1.10 

func (x *TapEvent_Http_RequestInit) GetHeaders() *http_types.Headers

func (*TapEvent_Http_RequestInit) GetId 

func (x *TapEvent_Http_RequestInit) GetId() *TapEvent_Http_StreamId

func (*TapEvent_Http_RequestInit) GetMethod 

func (x *TapEvent_Http_RequestInit) GetMethod() *http_types.HttpMethod

func (*TapEvent_Http_RequestInit) GetPath 

func (x *TapEvent_Http_RequestInit) GetPath() string

func (*TapEvent_Http_RequestInit) GetScheme 

func (x *TapEvent_Http_RequestInit) GetScheme() *http_types.Scheme

func (*TapEvent_Http_RequestInit) ProtoMessage 

func (*TapEvent_Http_RequestInit) ProtoMessage()

func (*TapEvent_Http_RequestInit) ProtoReflect added in v0.1.13 

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

func (*TapEvent_Http_RequestInit) Reset 

func (x *TapEvent_Http_RequestInit) Reset()

func (*TapEvent_Http_RequestInit) String 

func (x *TapEvent_Http_RequestInit) String() string

type TapEvent_Http_RequestInit_ 

type TapEvent_Http_RequestInit_ struct {
	RequestInit *TapEvent_Http_RequestInit `protobuf:"bytes,1,opt,name=request_init,json=requestInit,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"`
	Trailers          *http_types.Headers     `protobuf:"bytes,6,opt,name=trailers,proto3" json:"trailers,omitempty"`
	// contains filtered or unexported fields
}

func (*TapEvent_Http_ResponseEnd) Descriptor deprecated 

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

Deprecated: Use TapEvent_Http_ResponseEnd.ProtoReflect.Descriptor instead.

func (*TapEvent_Http_ResponseEnd) GetEos 

func (x *TapEvent_Http_ResponseEnd) GetEos() *Eos

func (*TapEvent_Http_ResponseEnd) GetId 

func (x *TapEvent_Http_ResponseEnd) GetId() *TapEvent_Http_StreamId

func (*TapEvent_Http_ResponseEnd) GetResponseBytes 

func (x *TapEvent_Http_ResponseEnd) GetResponseBytes() uint64

func (*TapEvent_Http_ResponseEnd) GetSinceRequestInit 

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

func (*TapEvent_Http_ResponseEnd) GetSinceResponseInit 

func (x *TapEvent_Http_ResponseEnd) GetSinceResponseInit() *duration.Duration

func (*TapEvent_Http_ResponseEnd) GetTrailers added in v0.1.10 

func (x *TapEvent_Http_ResponseEnd) GetTrailers() *http_types.Headers

func (*TapEvent_Http_ResponseEnd) ProtoMessage 

func (*TapEvent_Http_ResponseEnd) ProtoMessage()

func (*TapEvent_Http_ResponseEnd) ProtoReflect added in v0.1.13 

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

func (*TapEvent_Http_ResponseEnd) Reset 

func (x *TapEvent_Http_ResponseEnd) Reset()

func (*TapEvent_Http_ResponseEnd) String 

func (x *TapEvent_Http_ResponseEnd) String() string

type TapEvent_Http_ResponseEnd_ 

type TapEvent_Http_ResponseEnd_ struct {
	ResponseEnd *TapEvent_Http_ResponseEnd `protobuf:"bytes,3,opt,name=response_end,json=responseEnd,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"`
	Headers          *http_types.Headers     `protobuf:"bytes,4,opt,name=headers,proto3" json:"headers,omitempty"`
	// contains filtered or unexported fields
}

func (*TapEvent_Http_ResponseInit) Descriptor deprecated 

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

Deprecated: Use TapEvent_Http_ResponseInit.ProtoReflect.Descriptor instead.

func (*TapEvent_Http_ResponseInit) GetHeaders added in v0.1.10 

func (x *TapEvent_Http_ResponseInit) GetHeaders() *http_types.Headers

func (*TapEvent_Http_ResponseInit) GetHttpStatus 

func (x *TapEvent_Http_ResponseInit) GetHttpStatus() uint32

func (*TapEvent_Http_ResponseInit) GetId 

func (x *TapEvent_Http_ResponseInit) GetId() *TapEvent_Http_StreamId

func (*TapEvent_Http_ResponseInit) GetSinceRequestInit 

func (x *TapEvent_Http_ResponseInit) GetSinceRequestInit() *duration.Duration

func (*TapEvent_Http_ResponseInit) ProtoMessage 

func (*TapEvent_Http_ResponseInit) ProtoMessage()

func (*TapEvent_Http_ResponseInit) ProtoReflect added in v0.1.13 

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

func (*TapEvent_Http_ResponseInit) Reset 

func (x *TapEvent_Http_ResponseInit) Reset()

func (*TapEvent_Http_ResponseInit) String 

func (x *TapEvent_Http_ResponseInit) String() string

type TapEvent_Http_ResponseInit_ 

type TapEvent_Http_ResponseInit_ struct {
	ResponseInit *TapEvent_Http_ResponseInit `protobuf:"bytes,2,opt,name=response_init,json=responseInit,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"`
	// contains filtered or unexported fields
}

func (*TapEvent_Http_StreamId) Descriptor deprecated 

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

Deprecated: Use TapEvent_Http_StreamId.ProtoReflect.Descriptor instead.

func (*TapEvent_Http_StreamId) GetBase 

func (x *TapEvent_Http_StreamId) GetBase() uint32

func (*TapEvent_Http_StreamId) GetStream 

func (x *TapEvent_Http_StreamId) GetStream() uint64

func (*TapEvent_Http_StreamId) ProtoMessage 

func (*TapEvent_Http_StreamId) ProtoMessage()

func (*TapEvent_Http_StreamId) ProtoReflect added in v0.1.13 

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

func (*TapEvent_Http_StreamId) Reset 

func (x *TapEvent_Http_StreamId) Reset()

func (*TapEvent_Http_StreamId) String 

func (x *TapEvent_Http_StreamId) String() string

type TapEvent_ProxyDirection 

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

func (TapEvent_ProxyDirection) Descriptor added in v0.1.13 

func (TapEvent_ProxyDirection) Descriptor() protoreflect.EnumDescriptor

func (TapEvent_ProxyDirection) Enum added in v0.1.13 

func (x TapEvent_ProxyDirection) Enum() *TapEvent_ProxyDirection

func (TapEvent_ProxyDirection) EnumDescriptor deprecated 

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

Deprecated: Use TapEvent_ProxyDirection.Descriptor instead.

func (TapEvent_ProxyDirection) Number added in v0.1.13 

func (x TapEvent_ProxyDirection) Number() protoreflect.EnumNumber

func (TapEvent_ProxyDirection) String 

func (x TapEvent_ProxyDirection) String() string

func (TapEvent_ProxyDirection) Type added in v0.1.13 

func (TapEvent_ProxyDirection) Type() protoreflect.EnumType

type TapEvent_RouteMeta added in v0.1.4 

type TapEvent_RouteMeta struct {
	Labels map[string]string `` /* 153-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*TapEvent_RouteMeta) Descriptor deprecated added in v0.1.4 

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

Deprecated: Use TapEvent_RouteMeta.ProtoReflect.Descriptor instead.

func (*TapEvent_RouteMeta) GetLabels added in v0.1.4 

func (x *TapEvent_RouteMeta) GetLabels() map[string]string

func (*TapEvent_RouteMeta) ProtoMessage added in v0.1.4 

func (*TapEvent_RouteMeta) ProtoMessage()

func (*TapEvent_RouteMeta) ProtoReflect added in v0.1.13 

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

func (*TapEvent_RouteMeta) Reset added in v0.1.4 

func (x *TapEvent_RouteMeta) Reset()

func (*TapEvent_RouteMeta) String added in v0.1.4 

func (x *TapEvent_RouteMeta) String() string

type TapServer 

type TapServer interface {
	Observe(*ObserveRequest, grpc.ServerStreamingServer[TapEvent]) error
	// contains filtered or unexported methods
}

TapServer is the server API for Tap service. All implementations must embed UnimplementedTapServer for forward compatibility.

A service exposed by proxy instances to setup

type Tap_ObserveClient 

type Tap_ObserveClient = grpc.ServerStreamingClient[TapEvent]

This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.

type Tap_ObserveServer 

type Tap_ObserveServer = grpc.ServerStreamingServer[TapEvent]

This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.

type UnimplementedTapServer added in v0.1.13 

type UnimplementedTapServer struct{}

UnimplementedTapServer must be embedded to have forward compatible implementations.

NOTE: this should be embedded by value instead of pointer to avoid a nil pointer dereference when methods are called.

func (UnimplementedTapServer) Observe added in v0.1.13 

func (UnimplementedTapServer) Observe(*ObserveRequest, grpc.ServerStreamingServer[TapEvent]) error

type UnsafeTapServer added in v0.2.0 

type UnsafeTapServer interface {
	// contains filtered or unexported methods
}

UnsafeTapServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to TapServer will result in compilation errors.

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.