tap

package
v0.4.4 Latest Latest
Warning

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

 Go to latest Published: Jun 18, 2018 License: Apache-2.0 Imports: 6 Imported by: 0

Documentation

Overview

Package tap is a generated protocol buffer package.

It is generated from these files: 

proxy/tap.proto

It has these top-level messages: 

ObserveRequest

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func RegisterTapServer 

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

Types

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" json:"limit,omitempty"`
	// Encodes request-matching logic.
	Match *ObserveRequest_Match `protobuf:"bytes,2,opt,name=match" json:"match,omitempty"`
}

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

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
	Match isObserveRequest_Match_Match `protobuf_oneof:"match"`
}

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 added in v0.4.1 

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) 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_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.

type ObserveRequest_Match_All 

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

type ObserveRequest_Match_Any 

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

type ObserveRequest_Match_Destination 

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

type ObserveRequest_Match_DestinationLabel added in v0.4.1 

type ObserveRequest_Match_DestinationLabel struct {
	DestinationLabel *ObserveRequest_Match_Label `protobuf:"bytes,7,opt,name=destination_label,json=destinationLabel,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"`
}

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() *conduit_common.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() *conduit_common.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_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.

type ObserveRequest_Match_Http_ 

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

type ObserveRequest_Match_Http_Authority 

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

type ObserveRequest_Match_Http_Method 

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

type ObserveRequest_Match_Http_Path 

type ObserveRequest_Match_Http_Path struct {
	Path *ObserveRequest_Match_Http_StringMatch `protobuf:"bytes,4,opt,name=path,oneof"`
}

type ObserveRequest_Match_Http_Scheme 

type ObserveRequest_Match_Http_Scheme struct {
	Scheme *conduit_common.Scheme `protobuf:"bytes,1,opt,name=scheme,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"`
}

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_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.

type ObserveRequest_Match_Http_StringMatch_Exact 

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

type ObserveRequest_Match_Http_StringMatch_Prefix 

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

type ObserveRequest_Match_Label added in v0.4.1 

type ObserveRequest_Match_Label struct {
	Key   string `protobuf:"bytes,1,opt,name=key" json:"key,omitempty"`
	Value string `protobuf:"bytes,2,opt,name=value" json:"value,omitempty"`
}

func (*ObserveRequest_Match_Label) Descriptor added in v0.4.1 

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

func (*ObserveRequest_Match_Label) GetKey added in v0.4.1 

func (m *ObserveRequest_Match_Label) GetKey() string

func (*ObserveRequest_Match_Label) GetValue added in v0.4.1 

func (m *ObserveRequest_Match_Label) GetValue() string

func (*ObserveRequest_Match_Label) ProtoMessage added in v0.4.1 

func (*ObserveRequest_Match_Label) ProtoMessage()

func (*ObserveRequest_Match_Label) Reset added in v0.4.1 

func (m *ObserveRequest_Match_Label) Reset()

func (*ObserveRequest_Match_Label) String added in v0.4.1 

func (m *ObserveRequest_Match_Label) String() string

type ObserveRequest_Match_Not 

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

type ObserveRequest_Match_Seq 

type ObserveRequest_Match_Seq struct {
	Matches []*ObserveRequest_Match `protobuf:"bytes,1,rep,name=matches" json:"matches,omitempty"`
}

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

type ObserveRequest_Match_Source 

type ObserveRequest_Match_Source struct {
	Source *ObserveRequest_Match_Tcp `protobuf:"bytes,4,opt,name=source,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"`
}

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_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.

type ObserveRequest_Match_Tcp_Netmask 

type ObserveRequest_Match_Tcp_Netmask struct {
	Ip   *conduit_common.IPAddress `protobuf:"bytes,1,opt,name=ip" json:"ip,omitempty"`
	Mask uint32                    `protobuf:"varint,2,opt,name=mask" json:"mask,omitempty"`
}

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() *conduit_common.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

type ObserveRequest_Match_Tcp_Netmask_ 

type ObserveRequest_Match_Tcp_Netmask_ struct {
	Netmask *ObserveRequest_Match_Tcp_Netmask `protobuf:"bytes,1,opt,name=netmask,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" json:"min,omitempty"`
	// Maximum matching port value (inclusive), if specified.
	Max uint32 `protobuf:"varint,2,opt,name=max" json:"max,omitempty"`
}

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

type ObserveRequest_Match_Tcp_Ports 

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

type TapClient 

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

func NewTapClient 

func NewTapClient(cc *grpc.ClientConn) TapClient

type TapServer 

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

type Tap_ObserveClient 

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

type Tap_ObserveServer 

type Tap_ObserveServer interface {
	Send(*conduit_common.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.