tap

package
v0.1.6 Latest Latest
Warning

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

 Go to latest Published: Feb 5, 2019 License: Apache-2.0 Imports: 8 Imported by: 34

Documentation

Index

Constants

This section is empty.

Variables

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

Functions

func RegisterTapServer 

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

Types

type Eos 

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

func (*Eos) Descriptor 

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

func (*Eos) GetEnd 

func (m *Eos) GetEnd() isEos_End

func (*Eos) GetGrpcStatusCode 

func (m *Eos) GetGrpcStatusCode() uint32

func (*Eos) GetResetErrorCode 

func (m *Eos) GetResetErrorCode() uint32

func (*Eos) ProtoMessage 

func (*Eos) ProtoMessage()

func (*Eos) Reset 

func (m *Eos) Reset()

func (*Eos) String 

func (m *Eos) String() string

func (*Eos) XXX_DiscardUnknown added in v0.1.2 

func (m *Eos) XXX_DiscardUnknown()

func (*Eos) XXX_Marshal added in v0.1.2 

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

func (*Eos) XXX_Merge added in v0.1.2 

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

func (*Eos) XXX_OneofFuncs 

func (*Eos) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, func(msg proto.Message, tag, wire int, b *proto.Buffer) (bool, error), func(msg proto.Message) (n int), []interface{})

XXX_OneofFuncs is for the internal use of the proto package.

func (*Eos) XXX_Size added in v0.1.2 

func (m *Eos) XXX_Size() int

func (*Eos) XXX_Unmarshal added in v0.1.2 

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

type Eos_GrpcStatusCode 

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

type Eos_ResetErrorCode 

type Eos_ResetErrorCode struct {
	ResetErrorCode uint32 `protobuf:"varint,2,opt,name=reset_error_code,json=resetErrorCode,proto3,oneof"`
}

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

func (*ObserveRequest) Descriptor 

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

func (*ObserveRequest) GetLimit 

func (m *ObserveRequest) GetLimit() uint32

func (*ObserveRequest) GetMatch 

func (m *ObserveRequest) GetMatch() *ObserveRequest_Match

func (*ObserveRequest) ProtoMessage 

func (*ObserveRequest) ProtoMessage()

func (*ObserveRequest) Reset 

func (m *ObserveRequest) Reset()

func (*ObserveRequest) String 

func (m *ObserveRequest) String() string

func (*ObserveRequest) XXX_DiscardUnknown added in v0.1.2 

func (m *ObserveRequest) XXX_DiscardUnknown()

func (*ObserveRequest) XXX_Marshal added in v0.1.2 

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

func (*ObserveRequest) XXX_Merge added in v0.1.2 

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

func (*ObserveRequest) XXX_Size added in v0.1.2 

func (m *ObserveRequest) XXX_Size() int

func (*ObserveRequest) XXX_Unmarshal added in v0.1.2 

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

type ObserveRequest_Match 

type ObserveRequest_Match struct {
	// Types that are valid to be assigned 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"`
	XXX_NoUnkeyedLiteral struct{}                     `json:"-"`
	XXX_unrecognized     []byte                       `json:"-"`
	XXX_sizecache        int32                        `json:"-"`
}

func (*ObserveRequest_Match) Descriptor 

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

func (*ObserveRequest_Match) GetAll 

func (m *ObserveRequest_Match) GetAll() *ObserveRequest_Match_Seq

func (*ObserveRequest_Match) GetAny 

func (m *ObserveRequest_Match) GetAny() *ObserveRequest_Match_Seq

func (*ObserveRequest_Match) GetDestination 

func (m *ObserveRequest_Match) GetDestination() *ObserveRequest_Match_Tcp

func (*ObserveRequest_Match) GetDestinationLabel 

func (m *ObserveRequest_Match) GetDestinationLabel() *ObserveRequest_Match_Label

func (*ObserveRequest_Match) GetHttp 

func (m *ObserveRequest_Match) GetHttp() *ObserveRequest_Match_Http

func (*ObserveRequest_Match) GetMatch 

func (m *ObserveRequest_Match) GetMatch() isObserveRequest_Match_Match

func (*ObserveRequest_Match) GetNot 

func (m *ObserveRequest_Match) GetNot() *ObserveRequest_Match

func (*ObserveRequest_Match) GetRouteLabel added in v0.1.4 

func (m *ObserveRequest_Match) GetRouteLabel() *ObserveRequest_Match_Label

func (*ObserveRequest_Match) GetSource 

func (m *ObserveRequest_Match) GetSource() *ObserveRequest_Match_Tcp

func (*ObserveRequest_Match) ProtoMessage 

func (*ObserveRequest_Match) ProtoMessage()

func (*ObserveRequest_Match) Reset 

func (m *ObserveRequest_Match) Reset()

func (*ObserveRequest_Match) String 

func (m *ObserveRequest_Match) String() string

func (*ObserveRequest_Match) XXX_DiscardUnknown added in v0.1.2 

func (m *ObserveRequest_Match) XXX_DiscardUnknown()

func (*ObserveRequest_Match) XXX_Marshal added in v0.1.2 

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

func (*ObserveRequest_Match) XXX_Merge added in v0.1.2 

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

func (*ObserveRequest_Match) XXX_OneofFuncs 

func (*ObserveRequest_Match) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, func(msg proto.Message, tag, wire int, b *proto.Buffer) (bool, error), func(msg proto.Message) (n int), []interface{})

XXX_OneofFuncs is for the internal use of the proto package.

func (*ObserveRequest_Match) XXX_Size added in v0.1.2 

func (m *ObserveRequest_Match) XXX_Size() int

func (*ObserveRequest_Match) XXX_Unmarshal added in v0.1.2 

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

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

func (*ObserveRequest_Match_Http) Descriptor 

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

func (*ObserveRequest_Match_Http) GetAuthority 

func (m *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 (m *ObserveRequest_Match_Http) GetMethod() *http_types.HttpMethod

func (*ObserveRequest_Match_Http) GetPath 

func (m *ObserveRequest_Match_Http) GetPath() *ObserveRequest_Match_Http_StringMatch

func (*ObserveRequest_Match_Http) GetScheme 

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

func (*ObserveRequest_Match_Http) ProtoMessage 

func (*ObserveRequest_Match_Http) ProtoMessage()

func (*ObserveRequest_Match_Http) Reset 

func (m *ObserveRequest_Match_Http) Reset()

func (*ObserveRequest_Match_Http) String 

func (m *ObserveRequest_Match_Http) String() string

func (*ObserveRequest_Match_Http) XXX_DiscardUnknown added in v0.1.2 

func (m *ObserveRequest_Match_Http) XXX_DiscardUnknown()

func (*ObserveRequest_Match_Http) XXX_Marshal added in v0.1.2 

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

func (*ObserveRequest_Match_Http) XXX_Merge added in v0.1.2 

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

func (*ObserveRequest_Match_Http) XXX_OneofFuncs 

func (*ObserveRequest_Match_Http) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, func(msg proto.Message, tag, wire int, b *proto.Buffer) (bool, error), func(msg proto.Message) (n int), []interface{})

XXX_OneofFuncs is for the internal use of the proto package.

func (*ObserveRequest_Match_Http) XXX_Size added in v0.1.2 

func (m *ObserveRequest_Match_Http) XXX_Size() int

func (*ObserveRequest_Match_Http) XXX_Unmarshal added in v0.1.2 

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

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"`
}

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 valid to be assigned to Match:
	//	*ObserveRequest_Match_Http_StringMatch_Exact
	//	*ObserveRequest_Match_Http_StringMatch_Prefix
	Match                isObserveRequest_Match_Http_StringMatch_Match `protobuf_oneof:"match"`
	XXX_NoUnkeyedLiteral struct{}                                      `json:"-"`
	XXX_unrecognized     []byte                                        `json:"-"`
	XXX_sizecache        int32                                         `json:"-"`
}

func (*ObserveRequest_Match_Http_StringMatch) Descriptor 

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

func (*ObserveRequest_Match_Http_StringMatch) GetExact 

func (m *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 (m *ObserveRequest_Match_Http_StringMatch) GetPrefix() string

func (*ObserveRequest_Match_Http_StringMatch) ProtoMessage 

func (*ObserveRequest_Match_Http_StringMatch) ProtoMessage()

func (*ObserveRequest_Match_Http_StringMatch) Reset 

func (m *ObserveRequest_Match_Http_StringMatch) Reset()

func (*ObserveRequest_Match_Http_StringMatch) String 

func (m *ObserveRequest_Match_Http_StringMatch) String() string

func (*ObserveRequest_Match_Http_StringMatch) XXX_DiscardUnknown added in v0.1.2 

func (m *ObserveRequest_Match_Http_StringMatch) XXX_DiscardUnknown()

func (*ObserveRequest_Match_Http_StringMatch) XXX_Marshal added in v0.1.2 

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

func (*ObserveRequest_Match_Http_StringMatch) XXX_Merge added in v0.1.2 

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

func (*ObserveRequest_Match_Http_StringMatch) XXX_OneofFuncs 

func (*ObserveRequest_Match_Http_StringMatch) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, func(msg proto.Message, tag, wire int, b *proto.Buffer) (bool, error), func(msg proto.Message) (n int), []interface{})

XXX_OneofFuncs is for the internal use of the proto package.

func (*ObserveRequest_Match_Http_StringMatch) XXX_Size added in v0.1.2 

func (m *ObserveRequest_Match_Http_StringMatch) XXX_Size() int

func (*ObserveRequest_Match_Http_StringMatch) XXX_Unmarshal added in v0.1.2 

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

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

func (*ObserveRequest_Match_Label) Descriptor 

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

func (*ObserveRequest_Match_Label) GetKey 

func (m *ObserveRequest_Match_Label) GetKey() string

func (*ObserveRequest_Match_Label) GetValue 

func (m *ObserveRequest_Match_Label) GetValue() string

func (*ObserveRequest_Match_Label) ProtoMessage 

func (*ObserveRequest_Match_Label) ProtoMessage()

func (*ObserveRequest_Match_Label) Reset 

func (m *ObserveRequest_Match_Label) Reset()

func (*ObserveRequest_Match_Label) String 

func (m *ObserveRequest_Match_Label) String() string

func (*ObserveRequest_Match_Label) XXX_DiscardUnknown added in v0.1.2 

func (m *ObserveRequest_Match_Label) XXX_DiscardUnknown()

func (*ObserveRequest_Match_Label) XXX_Marshal added in v0.1.2 

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

func (*ObserveRequest_Match_Label) XXX_Merge added in v0.1.2 

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

func (*ObserveRequest_Match_Label) XXX_Size added in v0.1.2 

func (m *ObserveRequest_Match_Label) XXX_Size() int

func (*ObserveRequest_Match_Label) XXX_Unmarshal added in v0.1.2 

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

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

func (*ObserveRequest_Match_Seq) Descriptor 

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

func (*ObserveRequest_Match_Seq) GetMatches 

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

func (*ObserveRequest_Match_Seq) ProtoMessage 

func (*ObserveRequest_Match_Seq) ProtoMessage()

func (*ObserveRequest_Match_Seq) Reset 

func (m *ObserveRequest_Match_Seq) Reset()

func (*ObserveRequest_Match_Seq) String 

func (m *ObserveRequest_Match_Seq) String() string

func (*ObserveRequest_Match_Seq) XXX_DiscardUnknown added in v0.1.2 

func (m *ObserveRequest_Match_Seq) XXX_DiscardUnknown()

func (*ObserveRequest_Match_Seq) XXX_Marshal added in v0.1.2 

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

func (*ObserveRequest_Match_Seq) XXX_Merge added in v0.1.2 

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

func (*ObserveRequest_Match_Seq) XXX_Size added in v0.1.2 

func (m *ObserveRequest_Match_Seq) XXX_Size() int

func (*ObserveRequest_Match_Seq) XXX_Unmarshal added in v0.1.2 

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

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 valid to be assigned to Match:
	//	*ObserveRequest_Match_Tcp_Netmask_
	//	*ObserveRequest_Match_Tcp_Ports
	Match                isObserveRequest_Match_Tcp_Match `protobuf_oneof:"match"`
	XXX_NoUnkeyedLiteral struct{}                         `json:"-"`
	XXX_unrecognized     []byte                           `json:"-"`
	XXX_sizecache        int32                            `json:"-"`
}

func (*ObserveRequest_Match_Tcp) Descriptor 

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

func (*ObserveRequest_Match_Tcp) GetMatch 

func (m *ObserveRequest_Match_Tcp) GetMatch() isObserveRequest_Match_Tcp_Match

func (*ObserveRequest_Match_Tcp) GetNetmask 

func (m *ObserveRequest_Match_Tcp) GetNetmask() *ObserveRequest_Match_Tcp_Netmask

func (*ObserveRequest_Match_Tcp) GetPorts 

func (m *ObserveRequest_Match_Tcp) GetPorts() *ObserveRequest_Match_Tcp_PortRange

func (*ObserveRequest_Match_Tcp) ProtoMessage 

func (*ObserveRequest_Match_Tcp) ProtoMessage()

func (*ObserveRequest_Match_Tcp) Reset 

func (m *ObserveRequest_Match_Tcp) Reset()

func (*ObserveRequest_Match_Tcp) String 

func (m *ObserveRequest_Match_Tcp) String() string

func (*ObserveRequest_Match_Tcp) XXX_DiscardUnknown added in v0.1.2 

func (m *ObserveRequest_Match_Tcp) XXX_DiscardUnknown()

func (*ObserveRequest_Match_Tcp) XXX_Marshal added in v0.1.2 

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

func (*ObserveRequest_Match_Tcp) XXX_Merge added in v0.1.2 

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

func (*ObserveRequest_Match_Tcp) XXX_OneofFuncs 

func (*ObserveRequest_Match_Tcp) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, func(msg proto.Message, tag, wire int, b *proto.Buffer) (bool, error), func(msg proto.Message) (n int), []interface{})

XXX_OneofFuncs is for the internal use of the proto package.

func (*ObserveRequest_Match_Tcp) XXX_Size added in v0.1.2 

func (m *ObserveRequest_Match_Tcp) XXX_Size() int

func (*ObserveRequest_Match_Tcp) XXX_Unmarshal added in v0.1.2 

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

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

func (*ObserveRequest_Match_Tcp_Netmask) Descriptor 

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

func (*ObserveRequest_Match_Tcp_Netmask) GetIp 

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

func (*ObserveRequest_Match_Tcp_Netmask) GetMask 

func (m *ObserveRequest_Match_Tcp_Netmask) GetMask() uint32

func (*ObserveRequest_Match_Tcp_Netmask) ProtoMessage 

func (*ObserveRequest_Match_Tcp_Netmask) ProtoMessage()

func (*ObserveRequest_Match_Tcp_Netmask) Reset 

func (m *ObserveRequest_Match_Tcp_Netmask) Reset()

func (*ObserveRequest_Match_Tcp_Netmask) String 

func (m *ObserveRequest_Match_Tcp_Netmask) String() string

func (*ObserveRequest_Match_Tcp_Netmask) XXX_DiscardUnknown added in v0.1.2 

func (m *ObserveRequest_Match_Tcp_Netmask) XXX_DiscardUnknown()

func (*ObserveRequest_Match_Tcp_Netmask) XXX_Marshal added in v0.1.2 

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

func (*ObserveRequest_Match_Tcp_Netmask) XXX_Merge added in v0.1.2 

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

func (*ObserveRequest_Match_Tcp_Netmask) XXX_Size added in v0.1.2 

func (m *ObserveRequest_Match_Tcp_Netmask) XXX_Size() int

func (*ObserveRequest_Match_Tcp_Netmask) XXX_Unmarshal added in v0.1.2 

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

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

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 

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

func (*ObserveRequest_Match_Tcp_PortRange) GetMax 

func (m *ObserveRequest_Match_Tcp_PortRange) GetMax() uint32

func (*ObserveRequest_Match_Tcp_PortRange) GetMin 

func (m *ObserveRequest_Match_Tcp_PortRange) GetMin() uint32

func (*ObserveRequest_Match_Tcp_PortRange) ProtoMessage 

func (*ObserveRequest_Match_Tcp_PortRange) ProtoMessage()

func (*ObserveRequest_Match_Tcp_PortRange) Reset 

func (m *ObserveRequest_Match_Tcp_PortRange) Reset()

func (*ObserveRequest_Match_Tcp_PortRange) String 

func (m *ObserveRequest_Match_Tcp_PortRange) String() string

func (*ObserveRequest_Match_Tcp_PortRange) XXX_DiscardUnknown added in v0.1.2 

func (m *ObserveRequest_Match_Tcp_PortRange) XXX_DiscardUnknown()

func (*ObserveRequest_Match_Tcp_PortRange) XXX_Marshal added in v0.1.2 

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

func (*ObserveRequest_Match_Tcp_PortRange) XXX_Merge added in v0.1.2 

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

func (*ObserveRequest_Match_Tcp_PortRange) XXX_Size added in v0.1.2 

func (m *ObserveRequest_Match_Tcp_PortRange) XXX_Size() int

func (*ObserveRequest_Match_Tcp_PortRange) XXX_Unmarshal added in v0.1.2 

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

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) (Tap_ObserveClient, error)
}

TapClient is the client API for Tap service.

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

func NewTapClient 

func NewTapClient(cc *grpc.ClientConn) 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 valid to be assigned to Event:
	//	*TapEvent_Http_
	Event                isTapEvent_Event `protobuf_oneof:"event"`
	XXX_NoUnkeyedLiteral struct{}         `json:"-"`
	XXX_unrecognized     []byte           `json:"-"`
	XXX_sizecache        int32            `json:"-"`
}

func (*TapEvent) Descriptor 

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

func (*TapEvent) GetDestination 

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

func (*TapEvent) GetDestinationMeta 

func (m *TapEvent) GetDestinationMeta() *TapEvent_EndpointMeta

func (*TapEvent) GetEvent 

func (m *TapEvent) GetEvent() isTapEvent_Event

func (*TapEvent) GetHttp 

func (m *TapEvent) GetHttp() *TapEvent_Http

func (*TapEvent) GetProxyDirection 

func (m *TapEvent) GetProxyDirection() TapEvent_ProxyDirection

func (*TapEvent) GetRouteMeta added in v0.1.4 

func (m *TapEvent) GetRouteMeta() *TapEvent_RouteMeta

func (*TapEvent) GetSource 

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

func (*TapEvent) GetSourceMeta 

func (m *TapEvent) GetSourceMeta() *TapEvent_EndpointMeta

func (*TapEvent) ProtoMessage 

func (*TapEvent) ProtoMessage()

func (*TapEvent) Reset 

func (m *TapEvent) Reset()

func (*TapEvent) String 

func (m *TapEvent) String() string

func (*TapEvent) XXX_DiscardUnknown added in v0.1.2 

func (m *TapEvent) XXX_DiscardUnknown()

func (*TapEvent) XXX_Marshal added in v0.1.2 

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

func (*TapEvent) XXX_Merge added in v0.1.2 

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

func (*TapEvent) XXX_OneofFuncs 

func (*TapEvent) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, func(msg proto.Message, tag, wire int, b *proto.Buffer) (bool, error), func(msg proto.Message) (n int), []interface{})

XXX_OneofFuncs is for the internal use of the proto package.

func (*TapEvent) XXX_Size added in v0.1.2 

func (m *TapEvent) XXX_Size() int

func (*TapEvent) XXX_Unmarshal added in v0.1.2 

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

type TapEvent_EndpointMeta 

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

func (*TapEvent_EndpointMeta) Descriptor 

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

func (*TapEvent_EndpointMeta) GetLabels 

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

func (*TapEvent_EndpointMeta) ProtoMessage 

func (*TapEvent_EndpointMeta) ProtoMessage()

func (*TapEvent_EndpointMeta) Reset 

func (m *TapEvent_EndpointMeta) Reset()

func (*TapEvent_EndpointMeta) String 

func (m *TapEvent_EndpointMeta) String() string

func (*TapEvent_EndpointMeta) XXX_DiscardUnknown added in v0.1.2 

func (m *TapEvent_EndpointMeta) XXX_DiscardUnknown()

func (*TapEvent_EndpointMeta) XXX_Marshal added in v0.1.2 

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

func (*TapEvent_EndpointMeta) XXX_Merge added in v0.1.2 

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

func (*TapEvent_EndpointMeta) XXX_Size added in v0.1.2 

func (m *TapEvent_EndpointMeta) XXX_Size() int

func (*TapEvent_EndpointMeta) XXX_Unmarshal added in v0.1.2 

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

type TapEvent_Http 

type TapEvent_Http struct {
	// Types that are valid to be assigned to Event:
	//	*TapEvent_Http_RequestInit_
	//	*TapEvent_Http_ResponseInit_
	//	*TapEvent_Http_ResponseEnd_
	Event                isTapEvent_Http_Event `protobuf_oneof:"event"`
	XXX_NoUnkeyedLiteral struct{}              `json:"-"`
	XXX_unrecognized     []byte                `json:"-"`
	XXX_sizecache        int32                 `json:"-"`
}

func (*TapEvent_Http) Descriptor 

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

func (*TapEvent_Http) GetEvent 

func (m *TapEvent_Http) GetEvent() isTapEvent_Http_Event

func (*TapEvent_Http) GetRequestInit 

func (m *TapEvent_Http) GetRequestInit() *TapEvent_Http_RequestInit

func (*TapEvent_Http) GetResponseEnd 

func (m *TapEvent_Http) GetResponseEnd() *TapEvent_Http_ResponseEnd

func (*TapEvent_Http) GetResponseInit 

func (m *TapEvent_Http) GetResponseInit() *TapEvent_Http_ResponseInit

func (*TapEvent_Http) ProtoMessage 

func (*TapEvent_Http) ProtoMessage()

func (*TapEvent_Http) Reset 

func (m *TapEvent_Http) Reset()

func (*TapEvent_Http) String 

func (m *TapEvent_Http) String() string

func (*TapEvent_Http) XXX_DiscardUnknown added in v0.1.2 

func (m *TapEvent_Http) XXX_DiscardUnknown()

func (*TapEvent_Http) XXX_Marshal added in v0.1.2 

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

func (*TapEvent_Http) XXX_Merge added in v0.1.2 

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

func (*TapEvent_Http) XXX_OneofFuncs 

func (*TapEvent_Http) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, func(msg proto.Message, tag, wire int, b *proto.Buffer) (bool, error), func(msg proto.Message) (n int), []interface{})

XXX_OneofFuncs is for the internal use of the proto package.

func (*TapEvent_Http) XXX_Size added in v0.1.2 

func (m *TapEvent_Http) XXX_Size() int

func (*TapEvent_Http) XXX_Unmarshal added in v0.1.2 

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

type TapEvent_Http_ 

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

type TapEvent_Http_RequestInit 

type TapEvent_Http_RequestInit struct {
	Id                   *TapEvent_Http_StreamId `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Method               *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"`
	XXX_NoUnkeyedLiteral struct{}                `json:"-"`
	XXX_unrecognized     []byte                  `json:"-"`
	XXX_sizecache        int32                   `json:"-"`
}

func (*TapEvent_Http_RequestInit) Descriptor 

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

func (*TapEvent_Http_RequestInit) GetAuthority 

func (m *TapEvent_Http_RequestInit) GetAuthority() string

func (*TapEvent_Http_RequestInit) GetId 

func (m *TapEvent_Http_RequestInit) GetId() *TapEvent_Http_StreamId

func (*TapEvent_Http_RequestInit) GetMethod 

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

func (*TapEvent_Http_RequestInit) GetPath 

func (m *TapEvent_Http_RequestInit) GetPath() string

func (*TapEvent_Http_RequestInit) GetScheme 

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

func (*TapEvent_Http_RequestInit) ProtoMessage 

func (*TapEvent_Http_RequestInit) ProtoMessage()

func (*TapEvent_Http_RequestInit) Reset 

func (m *TapEvent_Http_RequestInit) Reset()

func (*TapEvent_Http_RequestInit) String 

func (m *TapEvent_Http_RequestInit) String() string

func (*TapEvent_Http_RequestInit) XXX_DiscardUnknown added in v0.1.2 

func (m *TapEvent_Http_RequestInit) XXX_DiscardUnknown()

func (*TapEvent_Http_RequestInit) XXX_Marshal added in v0.1.2 

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

func (*TapEvent_Http_RequestInit) XXX_Merge added in v0.1.2 

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

func (*TapEvent_Http_RequestInit) XXX_Size added in v0.1.2 

func (m *TapEvent_Http_RequestInit) XXX_Size() int

func (*TapEvent_Http_RequestInit) XXX_Unmarshal added in v0.1.2 

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

type TapEvent_Http_RequestInit_ 

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

type TapEvent_Http_ResponseEnd 

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

func (*TapEvent_Http_ResponseEnd) Descriptor 

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

func (*TapEvent_Http_ResponseEnd) GetEos 

func (m *TapEvent_Http_ResponseEnd) GetEos() *Eos

func (*TapEvent_Http_ResponseEnd) GetId 

func (m *TapEvent_Http_ResponseEnd) GetId() *TapEvent_Http_StreamId

func (*TapEvent_Http_ResponseEnd) GetResponseBytes 

func (m *TapEvent_Http_ResponseEnd) GetResponseBytes() uint64

func (*TapEvent_Http_ResponseEnd) GetSinceRequestInit 

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

func (*TapEvent_Http_ResponseEnd) GetSinceResponseInit 

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

func (*TapEvent_Http_ResponseEnd) ProtoMessage 

func (*TapEvent_Http_ResponseEnd) ProtoMessage()

func (*TapEvent_Http_ResponseEnd) Reset 

func (m *TapEvent_Http_ResponseEnd) Reset()

func (*TapEvent_Http_ResponseEnd) String 

func (m *TapEvent_Http_ResponseEnd) String() string

func (*TapEvent_Http_ResponseEnd) XXX_DiscardUnknown added in v0.1.2 

func (m *TapEvent_Http_ResponseEnd) XXX_DiscardUnknown()

func (*TapEvent_Http_ResponseEnd) XXX_Marshal added in v0.1.2 

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

func (*TapEvent_Http_ResponseEnd) XXX_Merge added in v0.1.2 

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

func (*TapEvent_Http_ResponseEnd) XXX_Size added in v0.1.2 

func (m *TapEvent_Http_ResponseEnd) XXX_Size() int

func (*TapEvent_Http_ResponseEnd) XXX_Unmarshal added in v0.1.2 

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

type TapEvent_Http_ResponseEnd_ 

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

type TapEvent_Http_ResponseInit 

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

func (*TapEvent_Http_ResponseInit) Descriptor 

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

func (*TapEvent_Http_ResponseInit) GetHttpStatus 

func (m *TapEvent_Http_ResponseInit) GetHttpStatus() uint32

func (*TapEvent_Http_ResponseInit) GetId 

func (m *TapEvent_Http_ResponseInit) GetId() *TapEvent_Http_StreamId

func (*TapEvent_Http_ResponseInit) GetSinceRequestInit 

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

func (*TapEvent_Http_ResponseInit) ProtoMessage 

func (*TapEvent_Http_ResponseInit) ProtoMessage()

func (*TapEvent_Http_ResponseInit) Reset 

func (m *TapEvent_Http_ResponseInit) Reset()

func (*TapEvent_Http_ResponseInit) String 

func (m *TapEvent_Http_ResponseInit) String() string

func (*TapEvent_Http_ResponseInit) XXX_DiscardUnknown added in v0.1.2 

func (m *TapEvent_Http_ResponseInit) XXX_DiscardUnknown()

func (*TapEvent_Http_ResponseInit) XXX_Marshal added in v0.1.2 

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

func (*TapEvent_Http_ResponseInit) XXX_Merge added in v0.1.2 

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

func (*TapEvent_Http_ResponseInit) XXX_Size added in v0.1.2 

func (m *TapEvent_Http_ResponseInit) XXX_Size() int

func (*TapEvent_Http_ResponseInit) XXX_Unmarshal added in v0.1.2 

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

type TapEvent_Http_ResponseInit_ 

type TapEvent_Http_ResponseInit_ struct {
	ResponseInit *TapEvent_Http_ResponseInit `protobuf:"bytes,2,opt,name=response_init,json=responseInit,proto3,oneof"`
}

type TapEvent_Http_StreamId 

type TapEvent_Http_StreamId struct {
	// A randomized base (stable across a process's runtime)
	Base uint32 `protobuf:"varint,1,opt,name=base,proto3" json:"base,omitempty"`
	// A stream id unique within the lifetime of `base`.
	Stream               uint64   `protobuf:"varint,2,opt,name=stream,proto3" json:"stream,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*TapEvent_Http_StreamId) Descriptor 

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

func (*TapEvent_Http_StreamId) GetBase 

func (m *TapEvent_Http_StreamId) GetBase() uint32

func (*TapEvent_Http_StreamId) GetStream 

func (m *TapEvent_Http_StreamId) GetStream() uint64

func (*TapEvent_Http_StreamId) ProtoMessage 

func (*TapEvent_Http_StreamId) ProtoMessage()

func (*TapEvent_Http_StreamId) Reset 

func (m *TapEvent_Http_StreamId) Reset()

func (*TapEvent_Http_StreamId) String 

func (m *TapEvent_Http_StreamId) String() string

func (*TapEvent_Http_StreamId) XXX_DiscardUnknown added in v0.1.2 

func (m *TapEvent_Http_StreamId) XXX_DiscardUnknown()

func (*TapEvent_Http_StreamId) XXX_Marshal added in v0.1.2 

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

func (*TapEvent_Http_StreamId) XXX_Merge added in v0.1.2 

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

func (*TapEvent_Http_StreamId) XXX_Size added in v0.1.2 

func (m *TapEvent_Http_StreamId) XXX_Size() int

func (*TapEvent_Http_StreamId) XXX_Unmarshal added in v0.1.2 

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

type TapEvent_ProxyDirection 

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

func (TapEvent_ProxyDirection) EnumDescriptor 

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

func (TapEvent_ProxyDirection) String 

func (x TapEvent_ProxyDirection) String() string

type TapEvent_RouteMeta added in v0.1.4 

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

func (*TapEvent_RouteMeta) Descriptor added in v0.1.4 

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

func (*TapEvent_RouteMeta) GetLabels added in v0.1.4 

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

func (*TapEvent_RouteMeta) ProtoMessage added in v0.1.4 

func (*TapEvent_RouteMeta) ProtoMessage()

func (*TapEvent_RouteMeta) Reset added in v0.1.4 

func (m *TapEvent_RouteMeta) Reset()

func (*TapEvent_RouteMeta) String added in v0.1.4 

func (m *TapEvent_RouteMeta) String() string

func (*TapEvent_RouteMeta) XXX_DiscardUnknown added in v0.1.4 

func (m *TapEvent_RouteMeta) XXX_DiscardUnknown()

func (*TapEvent_RouteMeta) XXX_Marshal added in v0.1.4 

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

func (*TapEvent_RouteMeta) XXX_Merge added in v0.1.4 

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

func (*TapEvent_RouteMeta) XXX_Size added in v0.1.4 

func (m *TapEvent_RouteMeta) XXX_Size() int

func (*TapEvent_RouteMeta) XXX_Unmarshal added in v0.1.4 

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

type TapServer 

type TapServer interface {
	Observe(*ObserveRequest, Tap_ObserveServer) error
}

TapServer is the server API for Tap service.

type Tap_ObserveClient 

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

type Tap_ObserveServer 

type Tap_ObserveServer interface {
	Send(*TapEvent) error
	grpc.ServerStream
}

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.