Versions in this module Expand all Collapse all v0 v0.5.0 Jul 5, 2018 Changes in this version + func RegisterTapServer(s *grpc.Server, srv TapServer) + type ObserveRequest struct + Limit uint32 + Match *ObserveRequest_Match + func (*ObserveRequest) Descriptor() ([]byte, []int) + func (*ObserveRequest) ProtoMessage() + func (m *ObserveRequest) GetLimit() uint32 + func (m *ObserveRequest) GetMatch() *ObserveRequest_Match + func (m *ObserveRequest) Reset() + func (m *ObserveRequest) String() string + type ObserveRequest_Match struct + Match isObserveRequest_Match_Match + func (*ObserveRequest_Match) Descriptor() ([]byte, []int) + func (*ObserveRequest_Match) ProtoMessage() + func (*ObserveRequest_Match) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, ...) + func (m *ObserveRequest_Match) GetAll() *ObserveRequest_Match_Seq + func (m *ObserveRequest_Match) GetAny() *ObserveRequest_Match_Seq + func (m *ObserveRequest_Match) GetDestination() *ObserveRequest_Match_Tcp + func (m *ObserveRequest_Match) GetDestinationLabel() *ObserveRequest_Match_Label + func (m *ObserveRequest_Match) GetHttp() *ObserveRequest_Match_Http + func (m *ObserveRequest_Match) GetMatch() isObserveRequest_Match_Match + func (m *ObserveRequest_Match) GetNot() *ObserveRequest_Match + func (m *ObserveRequest_Match) GetSource() *ObserveRequest_Match_Tcp + func (m *ObserveRequest_Match) Reset() + func (m *ObserveRequest_Match) String() string + type ObserveRequest_Match_All struct + All *ObserveRequest_Match_Seq + type ObserveRequest_Match_Any struct + Any *ObserveRequest_Match_Seq + type ObserveRequest_Match_Destination struct + Destination *ObserveRequest_Match_Tcp + type ObserveRequest_Match_DestinationLabel struct + DestinationLabel *ObserveRequest_Match_Label + type ObserveRequest_Match_Http struct + Match isObserveRequest_Match_Http_Match + func (*ObserveRequest_Match_Http) Descriptor() ([]byte, []int) + func (*ObserveRequest_Match_Http) ProtoMessage() + func (*ObserveRequest_Match_Http) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, ...) + func (m *ObserveRequest_Match_Http) GetAuthority() *ObserveRequest_Match_Http_StringMatch + func (m *ObserveRequest_Match_Http) GetMatch() isObserveRequest_Match_Http_Match + func (m *ObserveRequest_Match_Http) GetMethod() *conduit_common.HttpMethod + func (m *ObserveRequest_Match_Http) GetPath() *ObserveRequest_Match_Http_StringMatch + func (m *ObserveRequest_Match_Http) GetScheme() *conduit_common.Scheme + func (m *ObserveRequest_Match_Http) Reset() + func (m *ObserveRequest_Match_Http) String() string + type ObserveRequest_Match_Http_ struct + Http *ObserveRequest_Match_Http + type ObserveRequest_Match_Http_Authority struct + Authority *ObserveRequest_Match_Http_StringMatch + type ObserveRequest_Match_Http_Method struct + Method *conduit_common.HttpMethod + type ObserveRequest_Match_Http_Path struct + Path *ObserveRequest_Match_Http_StringMatch + type ObserveRequest_Match_Http_Scheme struct + Scheme *conduit_common.Scheme + type ObserveRequest_Match_Http_StringMatch struct + Match isObserveRequest_Match_Http_StringMatch_Match + func (*ObserveRequest_Match_Http_StringMatch) Descriptor() ([]byte, []int) + func (*ObserveRequest_Match_Http_StringMatch) ProtoMessage() + func (*ObserveRequest_Match_Http_StringMatch) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, ...) + func (m *ObserveRequest_Match_Http_StringMatch) GetExact() string + func (m *ObserveRequest_Match_Http_StringMatch) GetMatch() isObserveRequest_Match_Http_StringMatch_Match + func (m *ObserveRequest_Match_Http_StringMatch) GetPrefix() string + func (m *ObserveRequest_Match_Http_StringMatch) Reset() + func (m *ObserveRequest_Match_Http_StringMatch) String() string + type ObserveRequest_Match_Http_StringMatch_Exact struct + Exact string + type ObserveRequest_Match_Http_StringMatch_Prefix struct + Prefix string + type ObserveRequest_Match_Label struct + Key string + Value string + func (*ObserveRequest_Match_Label) Descriptor() ([]byte, []int) + func (*ObserveRequest_Match_Label) ProtoMessage() + func (m *ObserveRequest_Match_Label) GetKey() string + func (m *ObserveRequest_Match_Label) GetValue() string + func (m *ObserveRequest_Match_Label) Reset() + func (m *ObserveRequest_Match_Label) String() string + type ObserveRequest_Match_Not struct + Not *ObserveRequest_Match + type ObserveRequest_Match_Seq struct + Matches []*ObserveRequest_Match + func (*ObserveRequest_Match_Seq) Descriptor() ([]byte, []int) + func (*ObserveRequest_Match_Seq) ProtoMessage() + func (m *ObserveRequest_Match_Seq) GetMatches() []*ObserveRequest_Match + func (m *ObserveRequest_Match_Seq) Reset() + func (m *ObserveRequest_Match_Seq) String() string + type ObserveRequest_Match_Source struct + Source *ObserveRequest_Match_Tcp + type ObserveRequest_Match_Tcp struct + Match isObserveRequest_Match_Tcp_Match + func (*ObserveRequest_Match_Tcp) Descriptor() ([]byte, []int) + func (*ObserveRequest_Match_Tcp) ProtoMessage() + func (*ObserveRequest_Match_Tcp) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, ...) + func (m *ObserveRequest_Match_Tcp) GetMatch() isObserveRequest_Match_Tcp_Match + func (m *ObserveRequest_Match_Tcp) GetNetmask() *ObserveRequest_Match_Tcp_Netmask + func (m *ObserveRequest_Match_Tcp) GetPorts() *ObserveRequest_Match_Tcp_PortRange + func (m *ObserveRequest_Match_Tcp) Reset() + func (m *ObserveRequest_Match_Tcp) String() string + type ObserveRequest_Match_Tcp_Netmask struct + Ip *conduit_common.IPAddress + Mask uint32 + func (*ObserveRequest_Match_Tcp_Netmask) Descriptor() ([]byte, []int) + func (*ObserveRequest_Match_Tcp_Netmask) ProtoMessage() + func (m *ObserveRequest_Match_Tcp_Netmask) GetIp() *conduit_common.IPAddress + func (m *ObserveRequest_Match_Tcp_Netmask) GetMask() uint32 + func (m *ObserveRequest_Match_Tcp_Netmask) Reset() + func (m *ObserveRequest_Match_Tcp_Netmask) String() string + type ObserveRequest_Match_Tcp_Netmask_ struct + Netmask *ObserveRequest_Match_Tcp_Netmask + type ObserveRequest_Match_Tcp_PortRange struct + Max uint32 + Min uint32 + func (*ObserveRequest_Match_Tcp_PortRange) Descriptor() ([]byte, []int) + func (*ObserveRequest_Match_Tcp_PortRange) ProtoMessage() + func (m *ObserveRequest_Match_Tcp_PortRange) GetMax() uint32 + func (m *ObserveRequest_Match_Tcp_PortRange) GetMin() uint32 + func (m *ObserveRequest_Match_Tcp_PortRange) Reset() + func (m *ObserveRequest_Match_Tcp_PortRange) String() string + type ObserveRequest_Match_Tcp_Ports struct + Ports *ObserveRequest_Match_Tcp_PortRange + type TapClient interface + Observe func(ctx context.Context, in *ObserveRequest, opts ...grpc.CallOption) (Tap_ObserveClient, error) + func NewTapClient(cc *grpc.ClientConn) TapClient + type TapServer interface + Observe func(*ObserveRequest, Tap_ObserveServer) error + type Tap_ObserveClient interface + Recv func() (*conduit_common.TapEvent, error) + type Tap_ObserveServer interface + Send func(*conduit_common.TapEvent) error
Go to main page