Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security Policy
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

envoy_service_tap_v3alpha

package

Go to main page

Versions in this module

v0

v0.83.0

Oct 8, 2019

v0.83.0-rc2

Oct 8, 2019

v0.83.0-rc1

Oct 5, 2019

v0.82.0

Oct 2, 2019

Changes in this version

+ var ErrIntOverflowCommon = fmt.Errorf("proto: integer overflow")

+ var ErrIntOverflowTap = fmt.Errorf("proto: integer overflow")

+ var ErrIntOverflowTapds = fmt.Errorf("proto: integer overflow")

+ var ErrInvalidLengthCommon = fmt.Errorf("proto: negative length found during unmarshaling")

+ var ErrInvalidLengthTap = fmt.Errorf("proto: negative length found during unmarshaling")

+ var ErrInvalidLengthTapds = fmt.Errorf("proto: negative length found during unmarshaling")

+ var OutputSink_Format_name = map[int32]string

+ var OutputSink_Format_value = map[string]int32

+ func RegisterTapDiscoveryServiceServer(s *grpc.Server, srv TapDiscoveryServiceServer)

+ func RegisterTapSinkServiceServer(s *grpc.Server, srv TapSinkServiceServer)

+ type FilePerTapSink struct

+ PathPrefix string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*FilePerTapSink) Descriptor() ([]byte, []int)

+ func (*FilePerTapSink) ProtoMessage()

+ func (m *FilePerTapSink) GetPathPrefix() string

+ func (m *FilePerTapSink) Marshal() (dAtA []byte, err error)

+ func (m *FilePerTapSink) MarshalTo(dAtA []byte) (int, error)

+ func (m *FilePerTapSink) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *FilePerTapSink) Reset()

+ func (m *FilePerTapSink) Size() (n int)

+ func (m *FilePerTapSink) String() string

+ func (m *FilePerTapSink) Unmarshal(dAtA []byte) error

+ func (m *FilePerTapSink) Validate() error

+ func (m *FilePerTapSink) XXX_DiscardUnknown()

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

+ func (m *FilePerTapSink) XXX_Merge(src proto.Message)

+ func (m *FilePerTapSink) XXX_Size() int

+ func (m *FilePerTapSink) XXX_Unmarshal(b []byte) error

+ type FilePerTapSinkValidationError struct

+ func (e FilePerTapSinkValidationError) Cause() error

+ func (e FilePerTapSinkValidationError) Error() string

+ func (e FilePerTapSinkValidationError) ErrorName() string

+ func (e FilePerTapSinkValidationError) Field() string

+ func (e FilePerTapSinkValidationError) Key() bool

+ func (e FilePerTapSinkValidationError) Reason() string

+ type HttpHeadersMatch struct

+ Headers []*route.HeaderMatcher

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*HttpHeadersMatch) Descriptor() ([]byte, []int)

+ func (*HttpHeadersMatch) ProtoMessage()

+ func (m *HttpHeadersMatch) GetHeaders() []*route.HeaderMatcher

+ func (m *HttpHeadersMatch) Marshal() (dAtA []byte, err error)

+ func (m *HttpHeadersMatch) MarshalTo(dAtA []byte) (int, error)

+ func (m *HttpHeadersMatch) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *HttpHeadersMatch) Reset()

+ func (m *HttpHeadersMatch) Size() (n int)

+ func (m *HttpHeadersMatch) String() string

+ func (m *HttpHeadersMatch) Unmarshal(dAtA []byte) error

+ func (m *HttpHeadersMatch) Validate() error

+ func (m *HttpHeadersMatch) XXX_DiscardUnknown()

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

+ func (m *HttpHeadersMatch) XXX_Merge(src proto.Message)

+ func (m *HttpHeadersMatch) XXX_Size() int

+ func (m *HttpHeadersMatch) XXX_Unmarshal(b []byte) error

+ type HttpHeadersMatchValidationError struct

+ func (e HttpHeadersMatchValidationError) Cause() error

+ func (e HttpHeadersMatchValidationError) Error() string

+ func (e HttpHeadersMatchValidationError) ErrorName() string

+ func (e HttpHeadersMatchValidationError) Field() string

+ func (e HttpHeadersMatchValidationError) Key() bool

+ func (e HttpHeadersMatchValidationError) Reason() string

+ type MatchPredicate struct

+ Rule isMatchPredicate_Rule

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*MatchPredicate) Descriptor() ([]byte, []int)

+ func (*MatchPredicate) ProtoMessage()

+ func (*MatchPredicate) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, ...)

+ func (m *MatchPredicate) GetAndMatch() *MatchPredicate_MatchSet

+ func (m *MatchPredicate) GetAnyMatch() bool

+ func (m *MatchPredicate) GetHttpRequestHeadersMatch() *HttpHeadersMatch

+ func (m *MatchPredicate) GetHttpRequestTrailersMatch() *HttpHeadersMatch

+ func (m *MatchPredicate) GetHttpResponseHeadersMatch() *HttpHeadersMatch

+ func (m *MatchPredicate) GetHttpResponseTrailersMatch() *HttpHeadersMatch

+ func (m *MatchPredicate) GetNotMatch() *MatchPredicate

+ func (m *MatchPredicate) GetOrMatch() *MatchPredicate_MatchSet

+ func (m *MatchPredicate) GetRule() isMatchPredicate_Rule

+ func (m *MatchPredicate) Marshal() (dAtA []byte, err error)

+ func (m *MatchPredicate) MarshalTo(dAtA []byte) (int, error)

+ func (m *MatchPredicate) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *MatchPredicate) Reset()

+ func (m *MatchPredicate) Size() (n int)

+ func (m *MatchPredicate) String() string

+ func (m *MatchPredicate) Unmarshal(dAtA []byte) error

+ func (m *MatchPredicate) Validate() error

+ func (m *MatchPredicate) XXX_DiscardUnknown()

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

+ func (m *MatchPredicate) XXX_Merge(src proto.Message)

+ func (m *MatchPredicate) XXX_Size() int

+ func (m *MatchPredicate) XXX_Unmarshal(b []byte) error

+ type MatchPredicateValidationError struct

+ func (e MatchPredicateValidationError) Cause() error

+ func (e MatchPredicateValidationError) Error() string

+ func (e MatchPredicateValidationError) ErrorName() string

+ func (e MatchPredicateValidationError) Field() string

+ func (e MatchPredicateValidationError) Key() bool

+ func (e MatchPredicateValidationError) Reason() string

+ type MatchPredicate_AndMatch struct

+ AndMatch *MatchPredicate_MatchSet

+ func (m *MatchPredicate_AndMatch) MarshalTo(dAtA []byte) (int, error)

+ func (m *MatchPredicate_AndMatch) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *MatchPredicate_AndMatch) Size() (n int)

+ type MatchPredicate_AnyMatch struct

+ AnyMatch bool

+ func (m *MatchPredicate_AnyMatch) MarshalTo(dAtA []byte) (int, error)

+ func (m *MatchPredicate_AnyMatch) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *MatchPredicate_AnyMatch) Size() (n int)

+ type MatchPredicate_HttpRequestHeadersMatch struct

+ HttpRequestHeadersMatch *HttpHeadersMatch

+ func (m *MatchPredicate_HttpRequestHeadersMatch) MarshalTo(dAtA []byte) (int, error)

+ func (m *MatchPredicate_HttpRequestHeadersMatch) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *MatchPredicate_HttpRequestHeadersMatch) Size() (n int)

+ type MatchPredicate_HttpRequestTrailersMatch struct

+ HttpRequestTrailersMatch *HttpHeadersMatch

+ func (m *MatchPredicate_HttpRequestTrailersMatch) MarshalTo(dAtA []byte) (int, error)

+ func (m *MatchPredicate_HttpRequestTrailersMatch) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *MatchPredicate_HttpRequestTrailersMatch) Size() (n int)

+ type MatchPredicate_HttpResponseHeadersMatch struct

+ HttpResponseHeadersMatch *HttpHeadersMatch

+ func (m *MatchPredicate_HttpResponseHeadersMatch) MarshalTo(dAtA []byte) (int, error)

+ func (m *MatchPredicate_HttpResponseHeadersMatch) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *MatchPredicate_HttpResponseHeadersMatch) Size() (n int)

+ type MatchPredicate_HttpResponseTrailersMatch struct

+ HttpResponseTrailersMatch *HttpHeadersMatch

+ func (m *MatchPredicate_HttpResponseTrailersMatch) MarshalTo(dAtA []byte) (int, error)

+ func (m *MatchPredicate_HttpResponseTrailersMatch) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *MatchPredicate_HttpResponseTrailersMatch) Size() (n int)

+ type MatchPredicate_MatchSet struct

+ Rules []*MatchPredicate

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*MatchPredicate_MatchSet) Descriptor() ([]byte, []int)

+ func (*MatchPredicate_MatchSet) ProtoMessage()

+ func (m *MatchPredicate_MatchSet) GetRules() []*MatchPredicate

+ func (m *MatchPredicate_MatchSet) Marshal() (dAtA []byte, err error)

+ func (m *MatchPredicate_MatchSet) MarshalTo(dAtA []byte) (int, error)

+ func (m *MatchPredicate_MatchSet) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *MatchPredicate_MatchSet) Reset()

+ func (m *MatchPredicate_MatchSet) Size() (n int)

+ func (m *MatchPredicate_MatchSet) String() string

+ func (m *MatchPredicate_MatchSet) Unmarshal(dAtA []byte) error

+ func (m *MatchPredicate_MatchSet) Validate() error

+ func (m *MatchPredicate_MatchSet) XXX_DiscardUnknown()

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

+ func (m *MatchPredicate_MatchSet) XXX_Merge(src proto.Message)

+ func (m *MatchPredicate_MatchSet) XXX_Size() int

+ func (m *MatchPredicate_MatchSet) XXX_Unmarshal(b []byte) error

+ type MatchPredicate_MatchSetValidationError struct

+ func (e MatchPredicate_MatchSetValidationError) Cause() error

+ func (e MatchPredicate_MatchSetValidationError) Error() string

+ func (e MatchPredicate_MatchSetValidationError) ErrorName() string

+ func (e MatchPredicate_MatchSetValidationError) Field() string

+ func (e MatchPredicate_MatchSetValidationError) Key() bool

+ func (e MatchPredicate_MatchSetValidationError) Reason() string

+ type MatchPredicate_NotMatch struct

+ NotMatch *MatchPredicate

+ func (m *MatchPredicate_NotMatch) MarshalTo(dAtA []byte) (int, error)

+ func (m *MatchPredicate_NotMatch) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *MatchPredicate_NotMatch) Size() (n int)

+ type MatchPredicate_OrMatch struct

+ OrMatch *MatchPredicate_MatchSet

+ func (m *MatchPredicate_OrMatch) MarshalTo(dAtA []byte) (int, error)

+ func (m *MatchPredicate_OrMatch) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *MatchPredicate_OrMatch) Size() (n int)

+ type OutputConfig struct

+ MaxBufferedRxBytes *types.UInt32Value

+ MaxBufferedTxBytes *types.UInt32Value

+ Sinks []*OutputSink

+ Streaming bool

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*OutputConfig) Descriptor() ([]byte, []int)

+ func (*OutputConfig) ProtoMessage()

+ func (m *OutputConfig) GetMaxBufferedRxBytes() *types.UInt32Value

+ func (m *OutputConfig) GetMaxBufferedTxBytes() *types.UInt32Value

+ func (m *OutputConfig) GetSinks() []*OutputSink

+ func (m *OutputConfig) GetStreaming() bool

+ func (m *OutputConfig) Marshal() (dAtA []byte, err error)

+ func (m *OutputConfig) MarshalTo(dAtA []byte) (int, error)

+ func (m *OutputConfig) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *OutputConfig) Reset()

+ func (m *OutputConfig) Size() (n int)

+ func (m *OutputConfig) String() string

+ func (m *OutputConfig) Unmarshal(dAtA []byte) error

+ func (m *OutputConfig) Validate() error

+ func (m *OutputConfig) XXX_DiscardUnknown()

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

+ func (m *OutputConfig) XXX_Merge(src proto.Message)

+ func (m *OutputConfig) XXX_Size() int

+ func (m *OutputConfig) XXX_Unmarshal(b []byte) error

+ type OutputConfigValidationError struct

+ func (e OutputConfigValidationError) Cause() error

+ func (e OutputConfigValidationError) Error() string

+ func (e OutputConfigValidationError) ErrorName() string

+ func (e OutputConfigValidationError) Field() string

+ func (e OutputConfigValidationError) Key() bool

+ func (e OutputConfigValidationError) Reason() string

+ type OutputSink struct

+ Format OutputSink_Format

+ OutputSinkType isOutputSink_OutputSinkType

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*OutputSink) Descriptor() ([]byte, []int)

+ func (*OutputSink) ProtoMessage()

+ func (*OutputSink) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, ...)

+ func (m *OutputSink) GetFilePerTap() *FilePerTapSink

+ func (m *OutputSink) GetFormat() OutputSink_Format

+ func (m *OutputSink) GetOutputSinkType() isOutputSink_OutputSinkType

+ func (m *OutputSink) GetStreamingAdmin() *StreamingAdminSink

+ func (m *OutputSink) GetStreamingGrpc() *StreamingGrpcSink

+ func (m *OutputSink) Marshal() (dAtA []byte, err error)

+ func (m *OutputSink) MarshalTo(dAtA []byte) (int, error)

+ func (m *OutputSink) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *OutputSink) Reset()

+ func (m *OutputSink) Size() (n int)

+ func (m *OutputSink) String() string

+ func (m *OutputSink) Unmarshal(dAtA []byte) error

+ func (m *OutputSink) Validate() error

+ func (m *OutputSink) XXX_DiscardUnknown()

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

+ func (m *OutputSink) XXX_Merge(src proto.Message)

+ func (m *OutputSink) XXX_Size() int

+ func (m *OutputSink) XXX_Unmarshal(b []byte) error

+ type OutputSinkValidationError struct

+ func (e OutputSinkValidationError) Cause() error

+ func (e OutputSinkValidationError) Error() string

+ func (e OutputSinkValidationError) ErrorName() string

+ func (e OutputSinkValidationError) Field() string

+ func (e OutputSinkValidationError) Key() bool

+ func (e OutputSinkValidationError) Reason() string

+ type OutputSink_FilePerTap struct

+ FilePerTap *FilePerTapSink

+ func (m *OutputSink_FilePerTap) MarshalTo(dAtA []byte) (int, error)

+ func (m *OutputSink_FilePerTap) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *OutputSink_FilePerTap) Size() (n int)

+ type OutputSink_Format int32

+ const OutputSink_JSON_BODY_AS_BYTES

+ const OutputSink_JSON_BODY_AS_STRING

+ const OutputSink_PROTO_BINARY

+ const OutputSink_PROTO_BINARY_LENGTH_DELIMITED

+ const OutputSink_PROTO_TEXT

+ func (OutputSink_Format) EnumDescriptor() ([]byte, []int)

+ func (x OutputSink_Format) String() string

+ type OutputSink_StreamingAdmin struct

+ StreamingAdmin *StreamingAdminSink

+ func (m *OutputSink_StreamingAdmin) MarshalTo(dAtA []byte) (int, error)

+ func (m *OutputSink_StreamingAdmin) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *OutputSink_StreamingAdmin) Size() (n int)

+ type OutputSink_StreamingGrpc struct

+ StreamingGrpc *StreamingGrpcSink

+ func (m *OutputSink_StreamingGrpc) MarshalTo(dAtA []byte) (int, error)

+ func (m *OutputSink_StreamingGrpc) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *OutputSink_StreamingGrpc) Size() (n int)

+ type StreamTapsRequest struct

+ Identifier *StreamTapsRequest_Identifier

+ Trace *v3alpha.TraceWrapper

+ TraceId uint64

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*StreamTapsRequest) Descriptor() ([]byte, []int)

+ func (*StreamTapsRequest) ProtoMessage()

+ func (m *StreamTapsRequest) GetIdentifier() *StreamTapsRequest_Identifier

+ func (m *StreamTapsRequest) GetTrace() *v3alpha.TraceWrapper

+ func (m *StreamTapsRequest) GetTraceId() uint64

+ func (m *StreamTapsRequest) Marshal() (dAtA []byte, err error)

+ func (m *StreamTapsRequest) MarshalTo(dAtA []byte) (int, error)

+ func (m *StreamTapsRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *StreamTapsRequest) Reset()

+ func (m *StreamTapsRequest) Size() (n int)

+ func (m *StreamTapsRequest) String() string

+ func (m *StreamTapsRequest) Unmarshal(dAtA []byte) error

+ func (m *StreamTapsRequest) Validate() error

+ func (m *StreamTapsRequest) XXX_DiscardUnknown()

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

+ func (m *StreamTapsRequest) XXX_Merge(src proto.Message)

+ func (m *StreamTapsRequest) XXX_Size() int

+ func (m *StreamTapsRequest) XXX_Unmarshal(b []byte) error

+ type StreamTapsRequestValidationError struct

+ func (e StreamTapsRequestValidationError) Cause() error

+ func (e StreamTapsRequestValidationError) Error() string

+ func (e StreamTapsRequestValidationError) ErrorName() string

+ func (e StreamTapsRequestValidationError) Field() string

+ func (e StreamTapsRequestValidationError) Key() bool

+ func (e StreamTapsRequestValidationError) Reason() string

+ type StreamTapsRequest_Identifier struct

+ Node *core.Node

+ TapId string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*StreamTapsRequest_Identifier) Descriptor() ([]byte, []int)

+ func (*StreamTapsRequest_Identifier) ProtoMessage()

+ func (m *StreamTapsRequest_Identifier) GetNode() *core.Node

+ func (m *StreamTapsRequest_Identifier) GetTapId() string

+ func (m *StreamTapsRequest_Identifier) Marshal() (dAtA []byte, err error)

+ func (m *StreamTapsRequest_Identifier) MarshalTo(dAtA []byte) (int, error)

+ func (m *StreamTapsRequest_Identifier) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *StreamTapsRequest_Identifier) Reset()

+ func (m *StreamTapsRequest_Identifier) Size() (n int)

+ func (m *StreamTapsRequest_Identifier) String() string

+ func (m *StreamTapsRequest_Identifier) Unmarshal(dAtA []byte) error

+ func (m *StreamTapsRequest_Identifier) Validate() error

+ func (m *StreamTapsRequest_Identifier) XXX_DiscardUnknown()

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

+ func (m *StreamTapsRequest_Identifier) XXX_Merge(src proto.Message)

+ func (m *StreamTapsRequest_Identifier) XXX_Size() int

+ func (m *StreamTapsRequest_Identifier) XXX_Unmarshal(b []byte) error

+ type StreamTapsRequest_IdentifierValidationError struct

+ func (e StreamTapsRequest_IdentifierValidationError) Cause() error

+ func (e StreamTapsRequest_IdentifierValidationError) Error() string

+ func (e StreamTapsRequest_IdentifierValidationError) ErrorName() string

+ func (e StreamTapsRequest_IdentifierValidationError) Field() string

+ func (e StreamTapsRequest_IdentifierValidationError) Key() bool

+ func (e StreamTapsRequest_IdentifierValidationError) Reason() string

+ type StreamTapsResponse struct

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*StreamTapsResponse) Descriptor() ([]byte, []int)

+ func (*StreamTapsResponse) ProtoMessage()

+ func (m *StreamTapsResponse) Marshal() (dAtA []byte, err error)

+ func (m *StreamTapsResponse) MarshalTo(dAtA []byte) (int, error)

+ func (m *StreamTapsResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *StreamTapsResponse) Reset()

+ func (m *StreamTapsResponse) Size() (n int)

+ func (m *StreamTapsResponse) String() string

+ func (m *StreamTapsResponse) Unmarshal(dAtA []byte) error

+ func (m *StreamTapsResponse) Validate() error

+ func (m *StreamTapsResponse) XXX_DiscardUnknown()

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

+ func (m *StreamTapsResponse) XXX_Merge(src proto.Message)

+ func (m *StreamTapsResponse) XXX_Size() int

+ func (m *StreamTapsResponse) XXX_Unmarshal(b []byte) error

+ type StreamTapsResponseValidationError struct

+ func (e StreamTapsResponseValidationError) Cause() error

+ func (e StreamTapsResponseValidationError) Error() string

+ func (e StreamTapsResponseValidationError) ErrorName() string

+ func (e StreamTapsResponseValidationError) Field() string

+ func (e StreamTapsResponseValidationError) Key() bool

+ func (e StreamTapsResponseValidationError) Reason() string

+ type StreamingAdminSink struct

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*StreamingAdminSink) Descriptor() ([]byte, []int)

+ func (*StreamingAdminSink) ProtoMessage()

+ func (m *StreamingAdminSink) Marshal() (dAtA []byte, err error)

+ func (m *StreamingAdminSink) MarshalTo(dAtA []byte) (int, error)

+ func (m *StreamingAdminSink) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *StreamingAdminSink) Reset()

+ func (m *StreamingAdminSink) Size() (n int)

+ func (m *StreamingAdminSink) String() string

+ func (m *StreamingAdminSink) Unmarshal(dAtA []byte) error

+ func (m *StreamingAdminSink) Validate() error

+ func (m *StreamingAdminSink) XXX_DiscardUnknown()

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

+ func (m *StreamingAdminSink) XXX_Merge(src proto.Message)

+ func (m *StreamingAdminSink) XXX_Size() int

+ func (m *StreamingAdminSink) XXX_Unmarshal(b []byte) error

+ type StreamingAdminSinkValidationError struct

+ func (e StreamingAdminSinkValidationError) Cause() error

+ func (e StreamingAdminSinkValidationError) Error() string

+ func (e StreamingAdminSinkValidationError) ErrorName() string

+ func (e StreamingAdminSinkValidationError) Field() string

+ func (e StreamingAdminSinkValidationError) Key() bool

+ func (e StreamingAdminSinkValidationError) Reason() string

+ type StreamingGrpcSink struct

+ GrpcService *core.GrpcService

+ TapId string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*StreamingGrpcSink) Descriptor() ([]byte, []int)

+ func (*StreamingGrpcSink) ProtoMessage()

+ func (m *StreamingGrpcSink) GetGrpcService() *core.GrpcService

+ func (m *StreamingGrpcSink) GetTapId() string

+ func (m *StreamingGrpcSink) Marshal() (dAtA []byte, err error)

+ func (m *StreamingGrpcSink) MarshalTo(dAtA []byte) (int, error)

+ func (m *StreamingGrpcSink) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *StreamingGrpcSink) Reset()

+ func (m *StreamingGrpcSink) Size() (n int)

+ func (m *StreamingGrpcSink) String() string

+ func (m *StreamingGrpcSink) Unmarshal(dAtA []byte) error

+ func (m *StreamingGrpcSink) Validate() error

+ func (m *StreamingGrpcSink) XXX_DiscardUnknown()

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

+ func (m *StreamingGrpcSink) XXX_Merge(src proto.Message)

+ func (m *StreamingGrpcSink) XXX_Size() int

+ func (m *StreamingGrpcSink) XXX_Unmarshal(b []byte) error

+ type StreamingGrpcSinkValidationError struct

+ func (e StreamingGrpcSinkValidationError) Cause() error

+ func (e StreamingGrpcSinkValidationError) Error() string

+ func (e StreamingGrpcSinkValidationError) ErrorName() string

+ func (e StreamingGrpcSinkValidationError) Field() string

+ func (e StreamingGrpcSinkValidationError) Key() bool

+ func (e StreamingGrpcSinkValidationError) Reason() string

+ type TapConfig struct

+ MatchConfig *MatchPredicate

+ OutputConfig *OutputConfig

+ TapEnabled *core.RuntimeFractionalPercent

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*TapConfig) Descriptor() ([]byte, []int)

+ func (*TapConfig) ProtoMessage()

+ func (m *TapConfig) GetMatchConfig() *MatchPredicate

+ func (m *TapConfig) GetOutputConfig() *OutputConfig

+ func (m *TapConfig) GetTapEnabled() *core.RuntimeFractionalPercent

+ func (m *TapConfig) Marshal() (dAtA []byte, err error)

+ func (m *TapConfig) MarshalTo(dAtA []byte) (int, error)

+ func (m *TapConfig) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *TapConfig) Reset()

+ func (m *TapConfig) Size() (n int)

+ func (m *TapConfig) String() string

+ func (m *TapConfig) Unmarshal(dAtA []byte) error

+ func (m *TapConfig) Validate() error

+ func (m *TapConfig) XXX_DiscardUnknown()

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

+ func (m *TapConfig) XXX_Merge(src proto.Message)

+ func (m *TapConfig) XXX_Size() int

+ func (m *TapConfig) XXX_Unmarshal(b []byte) error

+ type TapConfigValidationError struct

+ func (e TapConfigValidationError) Cause() error

+ func (e TapConfigValidationError) Error() string

+ func (e TapConfigValidationError) ErrorName() string

+ func (e TapConfigValidationError) Field() string

+ func (e TapConfigValidationError) Key() bool

+ func (e TapConfigValidationError) Reason() string

+ type TapDiscoveryServiceClient interface

+ DeltaTapConfigs func(ctx context.Context, opts ...grpc.CallOption) (TapDiscoveryService_DeltaTapConfigsClient, error)

+ FetchTapConfigs func(ctx context.Context, in *v3alpha.DiscoveryRequest, opts ...grpc.CallOption) (*v3alpha.DiscoveryResponse, error)

+ StreamTapConfigs func(ctx context.Context, opts ...grpc.CallOption) (TapDiscoveryService_StreamTapConfigsClient, error)

+ func NewTapDiscoveryServiceClient(cc *grpc.ClientConn) TapDiscoveryServiceClient

+ type TapDiscoveryServiceServer interface

+ DeltaTapConfigs func(TapDiscoveryService_DeltaTapConfigsServer) error

+ FetchTapConfigs func(context.Context, *v3alpha.DiscoveryRequest) (*v3alpha.DiscoveryResponse, error)

+ StreamTapConfigs func(TapDiscoveryService_StreamTapConfigsServer) error

+ type TapDiscoveryService_DeltaTapConfigsClient interface

+ Recv func() (*v3alpha.DeltaDiscoveryResponse, error)

+ Send func(*v3alpha.DeltaDiscoveryRequest) error

+ type TapDiscoveryService_DeltaTapConfigsServer interface

+ Recv func() (*v3alpha.DeltaDiscoveryRequest, error)

+ Send func(*v3alpha.DeltaDiscoveryResponse) error

+ type TapDiscoveryService_StreamTapConfigsClient interface

+ Recv func() (*v3alpha.DiscoveryResponse, error)

+ Send func(*v3alpha.DiscoveryRequest) error

+ type TapDiscoveryService_StreamTapConfigsServer interface

+ Recv func() (*v3alpha.DiscoveryRequest, error)

+ Send func(*v3alpha.DiscoveryResponse) error

+ type TapResource struct

+ Config *TapConfig

+ Name string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*TapResource) Descriptor() ([]byte, []int)

+ func (*TapResource) ProtoMessage()

+ func (m *TapResource) GetConfig() *TapConfig

+ func (m *TapResource) GetName() string

+ func (m *TapResource) Marshal() (dAtA []byte, err error)

+ func (m *TapResource) MarshalTo(dAtA []byte) (int, error)

+ func (m *TapResource) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *TapResource) Reset()

+ func (m *TapResource) Size() (n int)

+ func (m *TapResource) String() string

+ func (m *TapResource) Unmarshal(dAtA []byte) error

+ func (m *TapResource) Validate() error

+ func (m *TapResource) XXX_DiscardUnknown()

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

+ func (m *TapResource) XXX_Merge(src proto.Message)

+ func (m *TapResource) XXX_Size() int

+ func (m *TapResource) XXX_Unmarshal(b []byte) error

+ type TapResourceValidationError struct

+ func (e TapResourceValidationError) Cause() error

+ func (e TapResourceValidationError) Error() string

+ func (e TapResourceValidationError) ErrorName() string

+ func (e TapResourceValidationError) Field() string

+ func (e TapResourceValidationError) Key() bool

+ func (e TapResourceValidationError) Reason() string

+ type TapSinkServiceClient interface

+ StreamTaps func(ctx context.Context, opts ...grpc.CallOption) (TapSinkService_StreamTapsClient, error)

+ func NewTapSinkServiceClient(cc *grpc.ClientConn) TapSinkServiceClient

+ type TapSinkServiceServer interface

+ StreamTaps func(TapSinkService_StreamTapsServer) error

+ type TapSinkService_StreamTapsClient interface

+ CloseAndRecv func() (*StreamTapsResponse, error)

+ Send func(*StreamTapsRequest) error

+ type TapSinkService_StreamTapsServer interface

+ Recv func() (*StreamTapsRequest, error)

+ SendAndClose func(*StreamTapsResponse) error

+ type UnimplementedTapDiscoveryServiceServer struct

+ func (*UnimplementedTapDiscoveryServiceServer) DeltaTapConfigs(srv TapDiscoveryService_DeltaTapConfigsServer) error

+ func (*UnimplementedTapDiscoveryServiceServer) FetchTapConfigs(ctx context.Context, req *v3alpha.DiscoveryRequest) (*v3alpha.DiscoveryResponse, error)

+ func (*UnimplementedTapDiscoveryServiceServer) StreamTapConfigs(srv TapDiscoveryService_StreamTapConfigsServer) error

+ type UnimplementedTapSinkServiceServer struct

+ func (*UnimplementedTapSinkServiceServer) StreamTaps(srv TapSinkService_StreamTapsServer) error

v0.82.0-rc1

Oct 2, 2019