Help us shape the future of Go! Take the 2026 Go Developer Survey

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.