const (
Tap_Observe_FullMethodName = "/io.linkerd.proxy.tap.Tap/Observe"
)
Enum value maps for TapEvent_ProxyDirection.
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,
}
)
var File_tap_proto protoreflect.FileDescriptor
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)
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", }
func RegisterTapServer(s grpc.ServiceRegistrar, srv TapServer)
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() ([]byte, []int)
Deprecated: Use Eos.ProtoReflect.Descriptor instead.
func (m *Eos) GetEnd() isEos_End
func (x *Eos) GetGrpcStatusCode() uint32
func (x *Eos) GetResetErrorCode() uint32
func (*Eos) ProtoMessage()
func (x *Eos) ProtoReflect() protoreflect.Message
func (x *Eos) Reset()
func (x *Eos) String() string
type Eos_GrpcStatusCode struct {
GrpcStatusCode uint32 `protobuf:"varint,1,opt,name=grpc_status_code,json=grpcStatusCode,proto3,oneof"`
}
type Eos_ResetErrorCode struct {
ResetErrorCode uint32 `protobuf:"varint,2,opt,name=reset_error_code,json=resetErrorCode,proto3,oneof"`
}
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() ([]byte, []int)
Deprecated: Use ObserveRequest.ProtoReflect.Descriptor instead.
func (x *ObserveRequest) GetExtract() *ObserveRequest_Extract
func (x *ObserveRequest) GetLimit() uint32
func (x *ObserveRequest) GetMatch() *ObserveRequest_Match
func (*ObserveRequest) ProtoMessage()
func (x *ObserveRequest) ProtoReflect() protoreflect.Message
func (x *ObserveRequest) Reset()
func (x *ObserveRequest) String() string
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() ([]byte, []int)
Deprecated: Use ObserveRequest_Extract.ProtoReflect.Descriptor instead.
func (m *ObserveRequest_Extract) GetExtract() isObserveRequest_Extract_Extract
func (x *ObserveRequest_Extract) GetHttp() *ObserveRequest_Extract_Http
func (*ObserveRequest_Extract) ProtoMessage()
func (x *ObserveRequest_Extract) ProtoReflect() protoreflect.Message
func (x *ObserveRequest_Extract) Reset()
func (x *ObserveRequest_Extract) String() string
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() ([]byte, []int)
Deprecated: Use ObserveRequest_Extract_Http.ProtoReflect.Descriptor instead.
func (m *ObserveRequest_Extract_Http) GetExtract() isObserveRequest_Extract_Http_Extract
func (x *ObserveRequest_Extract_Http) GetHeaders() *ObserveRequest_Extract_Http_Headers
func (*ObserveRequest_Extract_Http) ProtoMessage()
func (x *ObserveRequest_Extract_Http) ProtoReflect() protoreflect.Message
func (x *ObserveRequest_Extract_Http) Reset()
func (x *ObserveRequest_Extract_Http) String() string
type ObserveRequest_Extract_Http_ struct {
Http *ObserveRequest_Extract_Http `protobuf:"bytes,1,opt,name=http,proto3,oneof"`
}
type ObserveRequest_Extract_Http_Headers struct {
// contains filtered or unexported fields
}
func (*ObserveRequest_Extract_Http_Headers) Descriptor() ([]byte, []int)
Deprecated: Use ObserveRequest_Extract_Http_Headers.ProtoReflect.Descriptor instead.
func (*ObserveRequest_Extract_Http_Headers) ProtoMessage()
func (x *ObserveRequest_Extract_Http_Headers) ProtoReflect() protoreflect.Message
func (x *ObserveRequest_Extract_Http_Headers) Reset()
func (x *ObserveRequest_Extract_Http_Headers) String() string
type ObserveRequest_Extract_Http_Headers_ struct {
Headers *ObserveRequest_Extract_Http_Headers `protobuf:"bytes,1,opt,name=headers,proto3,oneof"`
}
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() ([]byte, []int)
Deprecated: Use ObserveRequest_Match.ProtoReflect.Descriptor instead.
func (x *ObserveRequest_Match) GetAll() *ObserveRequest_Match_Seq
func (x *ObserveRequest_Match) GetAny() *ObserveRequest_Match_Seq
func (x *ObserveRequest_Match) GetDestination() *ObserveRequest_Match_Tcp
func (x *ObserveRequest_Match) GetDestinationLabel() *ObserveRequest_Match_Label
func (x *ObserveRequest_Match) GetHttp() *ObserveRequest_Match_Http
func (m *ObserveRequest_Match) GetMatch() isObserveRequest_Match_Match
func (x *ObserveRequest_Match) GetNot() *ObserveRequest_Match
func (x *ObserveRequest_Match) GetRouteLabel() *ObserveRequest_Match_Label
func (x *ObserveRequest_Match) GetSource() *ObserveRequest_Match_Tcp
func (*ObserveRequest_Match) ProtoMessage()
func (x *ObserveRequest_Match) ProtoReflect() protoreflect.Message
func (x *ObserveRequest_Match) Reset()
func (x *ObserveRequest_Match) String() string
type ObserveRequest_Match_All struct {
All *ObserveRequest_Match_Seq `protobuf:"bytes,1,opt,name=all,proto3,oneof"`
}
type ObserveRequest_Match_Any struct {
Any *ObserveRequest_Match_Seq `protobuf:"bytes,2,opt,name=any,proto3,oneof"`
}
type ObserveRequest_Match_Destination struct {
Destination *ObserveRequest_Match_Tcp `protobuf:"bytes,5,opt,name=destination,proto3,oneof"`
}
type ObserveRequest_Match_DestinationLabel struct {
DestinationLabel *ObserveRequest_Match_Label `protobuf:"bytes,7,opt,name=destination_label,json=destinationLabel,proto3,oneof"`
}
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() ([]byte, []int)
Deprecated: Use ObserveRequest_Match_Http.ProtoReflect.Descriptor instead.
func (x *ObserveRequest_Match_Http) GetAuthority() *ObserveRequest_Match_Http_StringMatch
func (m *ObserveRequest_Match_Http) GetMatch() isObserveRequest_Match_Http_Match
func (x *ObserveRequest_Match_Http) GetMethod() *http_types.HttpMethod
func (x *ObserveRequest_Match_Http) GetPath() *ObserveRequest_Match_Http_StringMatch
func (x *ObserveRequest_Match_Http) GetScheme() *http_types.Scheme
func (*ObserveRequest_Match_Http) ProtoMessage()
func (x *ObserveRequest_Match_Http) ProtoReflect() protoreflect.Message
func (x *ObserveRequest_Match_Http) Reset()
func (x *ObserveRequest_Match_Http) String() string
type ObserveRequest_Match_Http_ struct {
Http *ObserveRequest_Match_Http `protobuf:"bytes,6,opt,name=http,proto3,oneof"`
}
type ObserveRequest_Match_Http_Authority struct {
Authority *ObserveRequest_Match_Http_StringMatch `protobuf:"bytes,2,opt,name=authority,proto3,oneof"`
}
type ObserveRequest_Match_Http_Method struct {
Method *http_types.HttpMethod `protobuf:"bytes,3,opt,name=method,proto3,oneof"`
}
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 struct {
Scheme *http_types.Scheme `protobuf:"bytes,1,opt,name=scheme,proto3,oneof"`
}
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() ([]byte, []int)
Deprecated: Use ObserveRequest_Match_Http_StringMatch.ProtoReflect.Descriptor instead.
func (x *ObserveRequest_Match_Http_StringMatch) GetExact() string
func (m *ObserveRequest_Match_Http_StringMatch) GetMatch() isObserveRequest_Match_Http_StringMatch_Match
func (x *ObserveRequest_Match_Http_StringMatch) GetPrefix() string
func (*ObserveRequest_Match_Http_StringMatch) ProtoMessage()
func (x *ObserveRequest_Match_Http_StringMatch) ProtoReflect() protoreflect.Message
func (x *ObserveRequest_Match_Http_StringMatch) Reset()
func (x *ObserveRequest_Match_Http_StringMatch) String() string
type ObserveRequest_Match_Http_StringMatch_Exact struct {
Exact string `protobuf:"bytes,1,opt,name=exact,proto3,oneof"`
}
type ObserveRequest_Match_Http_StringMatch_Prefix struct {
Prefix string `protobuf:"bytes,2,opt,name=prefix,proto3,oneof"`
}
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() ([]byte, []int)
Deprecated: Use ObserveRequest_Match_Label.ProtoReflect.Descriptor instead.
func (x *ObserveRequest_Match_Label) GetKey() string
func (x *ObserveRequest_Match_Label) GetValue() string
func (*ObserveRequest_Match_Label) ProtoMessage()
func (x *ObserveRequest_Match_Label) ProtoReflect() protoreflect.Message
func (x *ObserveRequest_Match_Label) Reset()
func (x *ObserveRequest_Match_Label) String() string
type ObserveRequest_Match_Not struct {
Not *ObserveRequest_Match `protobuf:"bytes,3,opt,name=not,proto3,oneof"`
}
type ObserveRequest_Match_RouteLabel struct {
RouteLabel *ObserveRequest_Match_Label `protobuf:"bytes,8,opt,name=route_label,json=routeLabel,proto3,oneof"`
}
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() ([]byte, []int)
Deprecated: Use ObserveRequest_Match_Seq.ProtoReflect.Descriptor instead.
func (x *ObserveRequest_Match_Seq) GetMatches() []*ObserveRequest_Match
func (*ObserveRequest_Match_Seq) ProtoMessage()
func (x *ObserveRequest_Match_Seq) ProtoReflect() protoreflect.Message
func (x *ObserveRequest_Match_Seq) Reset()
func (x *ObserveRequest_Match_Seq) String() string
type ObserveRequest_Match_Source struct {
Source *ObserveRequest_Match_Tcp `protobuf:"bytes,4,opt,name=source,proto3,oneof"`
}
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() ([]byte, []int)
Deprecated: Use ObserveRequest_Match_Tcp.ProtoReflect.Descriptor instead.
func (m *ObserveRequest_Match_Tcp) GetMatch() isObserveRequest_Match_Tcp_Match
func (x *ObserveRequest_Match_Tcp) GetNetmask() *ObserveRequest_Match_Tcp_Netmask
func (x *ObserveRequest_Match_Tcp) GetPorts() *ObserveRequest_Match_Tcp_PortRange
func (*ObserveRequest_Match_Tcp) ProtoMessage()
func (x *ObserveRequest_Match_Tcp) ProtoReflect() protoreflect.Message
func (x *ObserveRequest_Match_Tcp) Reset()
func (x *ObserveRequest_Match_Tcp) String() string
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() ([]byte, []int)
Deprecated: Use ObserveRequest_Match_Tcp_Netmask.ProtoReflect.Descriptor instead.
func (x *ObserveRequest_Match_Tcp_Netmask) GetIp() *net.IPAddress
func (x *ObserveRequest_Match_Tcp_Netmask) GetMask() uint32
func (*ObserveRequest_Match_Tcp_Netmask) ProtoMessage()
func (x *ObserveRequest_Match_Tcp_Netmask) ProtoReflect() protoreflect.Message
func (x *ObserveRequest_Match_Tcp_Netmask) Reset()
func (x *ObserveRequest_Match_Tcp_Netmask) String() string
type ObserveRequest_Match_Tcp_Netmask_ struct {
Netmask *ObserveRequest_Match_Tcp_Netmask `protobuf:"bytes,1,opt,name=netmask,proto3,oneof"`
}
If either a minimum or maximum is not specified, the range is considered to be over a discrete value.
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
}
func (*ObserveRequest_Match_Tcp_PortRange) Descriptor() ([]byte, []int)
Deprecated: Use ObserveRequest_Match_Tcp_PortRange.ProtoReflect.Descriptor instead.
func (x *ObserveRequest_Match_Tcp_PortRange) GetMax() uint32
func (x *ObserveRequest_Match_Tcp_PortRange) GetMin() uint32
func (*ObserveRequest_Match_Tcp_PortRange) ProtoMessage()
func (x *ObserveRequest_Match_Tcp_PortRange) ProtoReflect() protoreflect.Message
func (x *ObserveRequest_Match_Tcp_PortRange) Reset()
func (x *ObserveRequest_Match_Tcp_PortRange) String() string
type ObserveRequest_Match_Tcp_Ports struct {
Ports *ObserveRequest_Match_Tcp_PortRange `protobuf:"bytes,3,opt,name=ports,proto3,oneof"`
}
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.
type TapClient interface {
Observe(ctx context.Context, in *ObserveRequest, opts ...grpc.CallOption) (Tap_ObserveClient, error)
}
func NewTapClient(cc grpc.ClientConnInterface) TapClient
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 `protobuf:"varint,6,opt,name=proxy_direction,json=proxyDirection,proto3,enum=io.linkerd.proxy.tap.TapEvent_ProxyDirection" json:"proxy_direction,omitempty"`
// Types that are assignable to Event:
//
// *TapEvent_Http_
Event isTapEvent_Event `protobuf_oneof:"event"`
// contains filtered or unexported fields
}
func (*TapEvent) Descriptor() ([]byte, []int)
Deprecated: Use TapEvent.ProtoReflect.Descriptor instead.
func (x *TapEvent) GetDestination() *net.TcpAddress
func (x *TapEvent) GetDestinationMeta() *TapEvent_EndpointMeta
func (m *TapEvent) GetEvent() isTapEvent_Event
func (x *TapEvent) GetHttp() *TapEvent_Http
func (x *TapEvent) GetProxyDirection() TapEvent_ProxyDirection
func (x *TapEvent) GetRouteMeta() *TapEvent_RouteMeta
func (x *TapEvent) GetSource() *net.TcpAddress
func (x *TapEvent) GetSourceMeta() *TapEvent_EndpointMeta
func (*TapEvent) ProtoMessage()
func (x *TapEvent) ProtoReflect() protoreflect.Message
func (x *TapEvent) Reset()
func (x *TapEvent) String() string
type TapEvent_EndpointMeta struct {
Labels map[string]string `protobuf:"bytes,1,rep,name=labels,proto3" json:"labels,omitempty" protobuf_key:"bytes,1,opt,name=key,proto3" protobuf_val:"bytes,2,opt,name=value,proto3"`
// contains filtered or unexported fields
}
func (*TapEvent_EndpointMeta) Descriptor() ([]byte, []int)
Deprecated: Use TapEvent_EndpointMeta.ProtoReflect.Descriptor instead.
func (x *TapEvent_EndpointMeta) GetLabels() map[string]string
func (*TapEvent_EndpointMeta) ProtoMessage()
func (x *TapEvent_EndpointMeta) ProtoReflect() protoreflect.Message
func (x *TapEvent_EndpointMeta) Reset()
func (x *TapEvent_EndpointMeta) String() string
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() ([]byte, []int)
Deprecated: Use TapEvent_Http.ProtoReflect.Descriptor instead.
func (m *TapEvent_Http) GetEvent() isTapEvent_Http_Event
func (x *TapEvent_Http) GetRequestInit() *TapEvent_Http_RequestInit
func (x *TapEvent_Http) GetResponseEnd() *TapEvent_Http_ResponseEnd
func (x *TapEvent_Http) GetResponseInit() *TapEvent_Http_ResponseInit
func (*TapEvent_Http) ProtoMessage()
func (x *TapEvent_Http) ProtoReflect() protoreflect.Message
func (x *TapEvent_Http) Reset()
func (x *TapEvent_Http) String() string
type TapEvent_Http_ struct {
Http *TapEvent_Http `protobuf:"bytes,3,opt,name=http,proto3,oneof"`
}
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() ([]byte, []int)
Deprecated: Use TapEvent_Http_RequestInit.ProtoReflect.Descriptor instead.
func (x *TapEvent_Http_RequestInit) GetAuthority() string
func (x *TapEvent_Http_RequestInit) GetHeaders() *http_types.Headers
func (x *TapEvent_Http_RequestInit) GetId() *TapEvent_Http_StreamId
func (x *TapEvent_Http_RequestInit) GetMethod() *http_types.HttpMethod
func (x *TapEvent_Http_RequestInit) GetPath() string
func (x *TapEvent_Http_RequestInit) GetScheme() *http_types.Scheme
func (*TapEvent_Http_RequestInit) ProtoMessage()
func (x *TapEvent_Http_RequestInit) ProtoReflect() protoreflect.Message
func (x *TapEvent_Http_RequestInit) Reset()
func (x *TapEvent_Http_RequestInit) String() string
type TapEvent_Http_RequestInit_ struct {
RequestInit *TapEvent_Http_RequestInit `protobuf:"bytes,1,opt,name=request_init,json=requestInit,proto3,oneof"`
}
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() ([]byte, []int)
Deprecated: Use TapEvent_Http_ResponseEnd.ProtoReflect.Descriptor instead.
func (x *TapEvent_Http_ResponseEnd) GetEos() *Eos
func (x *TapEvent_Http_ResponseEnd) GetId() *TapEvent_Http_StreamId
func (x *TapEvent_Http_ResponseEnd) GetResponseBytes() uint64
func (x *TapEvent_Http_ResponseEnd) GetSinceRequestInit() *duration.Duration
func (x *TapEvent_Http_ResponseEnd) GetSinceResponseInit() *duration.Duration
func (x *TapEvent_Http_ResponseEnd) GetTrailers() *http_types.Headers
func (*TapEvent_Http_ResponseEnd) ProtoMessage()
func (x *TapEvent_Http_ResponseEnd) ProtoReflect() protoreflect.Message
func (x *TapEvent_Http_ResponseEnd) Reset()
func (x *TapEvent_Http_ResponseEnd) String() string
type TapEvent_Http_ResponseEnd_ struct {
ResponseEnd *TapEvent_Http_ResponseEnd `protobuf:"bytes,3,opt,name=response_end,json=responseEnd,proto3,oneof"`
}
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() ([]byte, []int)
Deprecated: Use TapEvent_Http_ResponseInit.ProtoReflect.Descriptor instead.
func (x *TapEvent_Http_ResponseInit) GetHeaders() *http_types.Headers
func (x *TapEvent_Http_ResponseInit) GetHttpStatus() uint32
func (x *TapEvent_Http_ResponseInit) GetId() *TapEvent_Http_StreamId
func (x *TapEvent_Http_ResponseInit) GetSinceRequestInit() *duration.Duration
func (*TapEvent_Http_ResponseInit) ProtoMessage()
func (x *TapEvent_Http_ResponseInit) ProtoReflect() protoreflect.Message
func (x *TapEvent_Http_ResponseInit) Reset()
func (x *TapEvent_Http_ResponseInit) String() string
type TapEvent_Http_ResponseInit_ struct {
ResponseInit *TapEvent_Http_ResponseInit `protobuf:"bytes,2,opt,name=response_init,json=responseInit,proto3,oneof"`
}
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() ([]byte, []int)
Deprecated: Use TapEvent_Http_StreamId.ProtoReflect.Descriptor instead.
func (x *TapEvent_Http_StreamId) GetBase() uint32
func (x *TapEvent_Http_StreamId) GetStream() uint64
func (*TapEvent_Http_StreamId) ProtoMessage()
func (x *TapEvent_Http_StreamId) ProtoReflect() protoreflect.Message
func (x *TapEvent_Http_StreamId) Reset()
func (x *TapEvent_Http_StreamId) String() string
type TapEvent_ProxyDirection int32
const (
TapEvent_UNKNOWN TapEvent_ProxyDirection = 0
TapEvent_INBOUND TapEvent_ProxyDirection = 1
TapEvent_OUTBOUND TapEvent_ProxyDirection = 2
)
func (TapEvent_ProxyDirection) Descriptor() protoreflect.EnumDescriptor
func (x TapEvent_ProxyDirection) Enum() *TapEvent_ProxyDirection
func (TapEvent_ProxyDirection) EnumDescriptor() ([]byte, []int)
Deprecated: Use TapEvent_ProxyDirection.Descriptor instead.
func (x TapEvent_ProxyDirection) Number() protoreflect.EnumNumber
func (x TapEvent_ProxyDirection) String() string
func (TapEvent_ProxyDirection) Type() protoreflect.EnumType
type TapEvent_RouteMeta struct {
Labels map[string]string `protobuf:"bytes,1,rep,name=labels,proto3" json:"labels,omitempty" protobuf_key:"bytes,1,opt,name=key,proto3" protobuf_val:"bytes,2,opt,name=value,proto3"`
// contains filtered or unexported fields
}
func (*TapEvent_RouteMeta) Descriptor() ([]byte, []int)
Deprecated: Use TapEvent_RouteMeta.ProtoReflect.Descriptor instead.
func (x *TapEvent_RouteMeta) GetLabels() map[string]string
func (*TapEvent_RouteMeta) ProtoMessage()
func (x *TapEvent_RouteMeta) ProtoReflect() protoreflect.Message
func (x *TapEvent_RouteMeta) Reset()
func (x *TapEvent_RouteMeta) String() string
TapServer is the server API for Tap service. All implementations must embed UnimplementedTapServer for forward compatibility
type TapServer interface {
Observe(*ObserveRequest, Tap_ObserveServer) error
// contains filtered or unexported methods
}
type Tap_ObserveClient interface {
Recv() (*TapEvent, error)
grpc.ClientStream
}
type Tap_ObserveServer interface {
Send(*TapEvent) error
grpc.ServerStream
}
UnimplementedTapServer must be embedded to have forward compatible implementations.
type UnimplementedTapServer struct {
}
func (UnimplementedTapServer) Observe(*ObserveRequest, Tap_ObserveServer) error
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.
type UnsafeTapServer interface {
// contains filtered or unexported methods
}