Documentation ¶
Index ¶
- Variables
- func RegisterTapDiscoveryServiceServer(s *grpc.Server, srv TapDiscoveryServiceServer)
- func RegisterTapSinkServiceServer(s *grpc.Server, srv TapSinkServiceServer)
- type StreamTapsRequest
- func (*StreamTapsRequest) Descriptor() ([]byte, []int)deprecated
- func (x *StreamTapsRequest) GetIdentifier() *StreamTapsRequest_Identifier
- func (x *StreamTapsRequest) GetTrace() *v3.TraceWrapper
- func (x *StreamTapsRequest) GetTraceId() uint64
- func (*StreamTapsRequest) ProtoMessage()
- func (x *StreamTapsRequest) ProtoReflect() protoreflect.Message
- func (x *StreamTapsRequest) Reset()
- func (x *StreamTapsRequest) String() string
- func (m *StreamTapsRequest) Validate() error
- type StreamTapsRequestValidationError
- 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
- func (*StreamTapsRequest_Identifier) Descriptor() ([]byte, []int)deprecated
- func (x *StreamTapsRequest_Identifier) GetNode() *v4alpha.Node
- func (x *StreamTapsRequest_Identifier) GetTapId() string
- func (*StreamTapsRequest_Identifier) ProtoMessage()
- func (x *StreamTapsRequest_Identifier) ProtoReflect() protoreflect.Message
- func (x *StreamTapsRequest_Identifier) Reset()
- func (x *StreamTapsRequest_Identifier) String() string
- func (m *StreamTapsRequest_Identifier) Validate() error
- type StreamTapsRequest_IdentifierValidationError
- 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
- func (*StreamTapsResponse) Descriptor() ([]byte, []int)deprecated
- func (*StreamTapsResponse) ProtoMessage()
- func (x *StreamTapsResponse) ProtoReflect() protoreflect.Message
- func (x *StreamTapsResponse) Reset()
- func (x *StreamTapsResponse) String() string
- func (m *StreamTapsResponse) Validate() error
- type StreamTapsResponseValidationError
- 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 TapDiscoveryServiceClient
- type TapDiscoveryServiceServer
- type TapDiscoveryService_DeltaTapConfigsClient
- type TapDiscoveryService_DeltaTapConfigsServer
- type TapDiscoveryService_StreamTapConfigsClient
- type TapDiscoveryService_StreamTapConfigsServer
- type TapResource
- func (*TapResource) Descriptor() ([]byte, []int)deprecated
- func (x *TapResource) GetConfig() *v4alpha.TapConfig
- func (x *TapResource) GetName() string
- func (*TapResource) ProtoMessage()
- func (x *TapResource) ProtoReflect() protoreflect.Message
- func (x *TapResource) Reset()
- func (x *TapResource) String() string
- func (m *TapResource) Validate() error
- type TapResourceValidationError
- 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
- type TapSinkServiceServer
- type TapSinkService_StreamTapsClient
- type TapSinkService_StreamTapsServer
- type UnimplementedTapDiscoveryServiceServer
- func (*UnimplementedTapDiscoveryServiceServer) DeltaTapConfigs(TapDiscoveryService_DeltaTapConfigsServer) error
- func (*UnimplementedTapDiscoveryServiceServer) FetchTapConfigs(context.Context, *v3.DiscoveryRequest) (*v3.DiscoveryResponse, error)
- func (*UnimplementedTapDiscoveryServiceServer) StreamTapConfigs(TapDiscoveryService_StreamTapConfigsServer) error
- type UnimplementedTapSinkServiceServer
Constants ¶
This section is empty.
Variables ¶
var File_envoy_service_tap_v4alpha_tap_proto protoreflect.FileDescriptor
var File_envoy_service_tap_v4alpha_tapds_proto protoreflect.FileDescriptor
Functions ¶
func RegisterTapDiscoveryServiceServer ¶
func RegisterTapDiscoveryServiceServer(s *grpc.Server, srv TapDiscoveryServiceServer)
func RegisterTapSinkServiceServer ¶
func RegisterTapSinkServiceServer(s *grpc.Server, srv TapSinkServiceServer)
Types ¶
type StreamTapsRequest ¶
type StreamTapsRequest struct { Identifier *StreamTapsRequest_Identifier `protobuf:"bytes,1,opt,name=identifier,proto3" json:"identifier,omitempty"` TraceId uint64 `protobuf:"varint,2,opt,name=trace_id,json=traceId,proto3" json:"trace_id,omitempty"` Trace *v3.TraceWrapper `protobuf:"bytes,3,opt,name=trace,proto3" json:"trace,omitempty"` // contains filtered or unexported fields }
func (*StreamTapsRequest) Descriptor
deprecated
func (*StreamTapsRequest) Descriptor() ([]byte, []int)
Deprecated: Use StreamTapsRequest.ProtoReflect.Descriptor instead.
func (*StreamTapsRequest) GetIdentifier ¶
func (x *StreamTapsRequest) GetIdentifier() *StreamTapsRequest_Identifier
func (*StreamTapsRequest) GetTrace ¶
func (x *StreamTapsRequest) GetTrace() *v3.TraceWrapper
func (*StreamTapsRequest) GetTraceId ¶
func (x *StreamTapsRequest) GetTraceId() uint64
func (*StreamTapsRequest) ProtoMessage ¶
func (*StreamTapsRequest) ProtoMessage()
func (*StreamTapsRequest) ProtoReflect ¶
func (x *StreamTapsRequest) ProtoReflect() protoreflect.Message
func (*StreamTapsRequest) Reset ¶
func (x *StreamTapsRequest) Reset()
func (*StreamTapsRequest) String ¶
func (x *StreamTapsRequest) String() string
func (*StreamTapsRequest) Validate ¶
func (m *StreamTapsRequest) Validate() error
Validate checks the field values on StreamTapsRequest with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.
type StreamTapsRequestValidationError ¶
type StreamTapsRequestValidationError struct {
// contains filtered or unexported fields
}
StreamTapsRequestValidationError is the validation error returned by StreamTapsRequest.Validate if the designated constraints aren't met.
func (StreamTapsRequestValidationError) Cause ¶
func (e StreamTapsRequestValidationError) Cause() error
Cause function returns cause value.
func (StreamTapsRequestValidationError) Error ¶
func (e StreamTapsRequestValidationError) Error() string
Error satisfies the builtin error interface
func (StreamTapsRequestValidationError) ErrorName ¶
func (e StreamTapsRequestValidationError) ErrorName() string
ErrorName returns error name.
func (StreamTapsRequestValidationError) Field ¶
func (e StreamTapsRequestValidationError) Field() string
Field function returns field value.
func (StreamTapsRequestValidationError) Key ¶
func (e StreamTapsRequestValidationError) Key() bool
Key function returns key value.
func (StreamTapsRequestValidationError) Reason ¶
func (e StreamTapsRequestValidationError) Reason() string
Reason function returns reason value.
type StreamTapsRequest_Identifier ¶
type StreamTapsRequest_Identifier struct { Node *v4alpha.Node `protobuf:"bytes,1,opt,name=node,proto3" json:"node,omitempty"` TapId string `protobuf:"bytes,2,opt,name=tap_id,json=tapId,proto3" json:"tap_id,omitempty"` // contains filtered or unexported fields }
func (*StreamTapsRequest_Identifier) Descriptor
deprecated
func (*StreamTapsRequest_Identifier) Descriptor() ([]byte, []int)
Deprecated: Use StreamTapsRequest_Identifier.ProtoReflect.Descriptor instead.
func (*StreamTapsRequest_Identifier) GetNode ¶
func (x *StreamTapsRequest_Identifier) GetNode() *v4alpha.Node
func (*StreamTapsRequest_Identifier) GetTapId ¶
func (x *StreamTapsRequest_Identifier) GetTapId() string
func (*StreamTapsRequest_Identifier) ProtoMessage ¶
func (*StreamTapsRequest_Identifier) ProtoMessage()
func (*StreamTapsRequest_Identifier) ProtoReflect ¶
func (x *StreamTapsRequest_Identifier) ProtoReflect() protoreflect.Message
func (*StreamTapsRequest_Identifier) Reset ¶
func (x *StreamTapsRequest_Identifier) Reset()
func (*StreamTapsRequest_Identifier) String ¶
func (x *StreamTapsRequest_Identifier) String() string
func (*StreamTapsRequest_Identifier) Validate ¶
func (m *StreamTapsRequest_Identifier) Validate() error
Validate checks the field values on StreamTapsRequest_Identifier with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.
type StreamTapsRequest_IdentifierValidationError ¶
type StreamTapsRequest_IdentifierValidationError struct {
// contains filtered or unexported fields
}
StreamTapsRequest_IdentifierValidationError is the validation error returned by StreamTapsRequest_Identifier.Validate if the designated constraints aren't met.
func (StreamTapsRequest_IdentifierValidationError) Cause ¶
func (e StreamTapsRequest_IdentifierValidationError) Cause() error
Cause function returns cause value.
func (StreamTapsRequest_IdentifierValidationError) Error ¶
func (e StreamTapsRequest_IdentifierValidationError) Error() string
Error satisfies the builtin error interface
func (StreamTapsRequest_IdentifierValidationError) ErrorName ¶
func (e StreamTapsRequest_IdentifierValidationError) ErrorName() string
ErrorName returns error name.
func (StreamTapsRequest_IdentifierValidationError) Field ¶
func (e StreamTapsRequest_IdentifierValidationError) Field() string
Field function returns field value.
func (StreamTapsRequest_IdentifierValidationError) Key ¶
func (e StreamTapsRequest_IdentifierValidationError) Key() bool
Key function returns key value.
func (StreamTapsRequest_IdentifierValidationError) Reason ¶
func (e StreamTapsRequest_IdentifierValidationError) Reason() string
Reason function returns reason value.
type StreamTapsResponse ¶
type StreamTapsResponse struct {
// contains filtered or unexported fields
}
func (*StreamTapsResponse) Descriptor
deprecated
func (*StreamTapsResponse) Descriptor() ([]byte, []int)
Deprecated: Use StreamTapsResponse.ProtoReflect.Descriptor instead.
func (*StreamTapsResponse) ProtoMessage ¶
func (*StreamTapsResponse) ProtoMessage()
func (*StreamTapsResponse) ProtoReflect ¶
func (x *StreamTapsResponse) ProtoReflect() protoreflect.Message
func (*StreamTapsResponse) Reset ¶
func (x *StreamTapsResponse) Reset()
func (*StreamTapsResponse) String ¶
func (x *StreamTapsResponse) String() string
func (*StreamTapsResponse) Validate ¶
func (m *StreamTapsResponse) Validate() error
Validate checks the field values on StreamTapsResponse with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.
type StreamTapsResponseValidationError ¶
type StreamTapsResponseValidationError struct {
// contains filtered or unexported fields
}
StreamTapsResponseValidationError is the validation error returned by StreamTapsResponse.Validate if the designated constraints aren't met.
func (StreamTapsResponseValidationError) Cause ¶
func (e StreamTapsResponseValidationError) Cause() error
Cause function returns cause value.
func (StreamTapsResponseValidationError) Error ¶
func (e StreamTapsResponseValidationError) Error() string
Error satisfies the builtin error interface
func (StreamTapsResponseValidationError) ErrorName ¶
func (e StreamTapsResponseValidationError) ErrorName() string
ErrorName returns error name.
func (StreamTapsResponseValidationError) Field ¶
func (e StreamTapsResponseValidationError) Field() string
Field function returns field value.
func (StreamTapsResponseValidationError) Key ¶
func (e StreamTapsResponseValidationError) Key() bool
Key function returns key value.
func (StreamTapsResponseValidationError) Reason ¶
func (e StreamTapsResponseValidationError) Reason() string
Reason function returns reason value.
type TapDiscoveryServiceClient ¶
type TapDiscoveryServiceClient interface { StreamTapConfigs(ctx context.Context, opts ...grpc.CallOption) (TapDiscoveryService_StreamTapConfigsClient, error) DeltaTapConfigs(ctx context.Context, opts ...grpc.CallOption) (TapDiscoveryService_DeltaTapConfigsClient, error) FetchTapConfigs(ctx context.Context, in *v3.DiscoveryRequest, opts ...grpc.CallOption) (*v3.DiscoveryResponse, error) }
TapDiscoveryServiceClient is the client API for TapDiscoveryService service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.
func NewTapDiscoveryServiceClient ¶
func NewTapDiscoveryServiceClient(cc grpc.ClientConnInterface) TapDiscoveryServiceClient
type TapDiscoveryServiceServer ¶
type TapDiscoveryServiceServer interface { StreamTapConfigs(TapDiscoveryService_StreamTapConfigsServer) error DeltaTapConfigs(TapDiscoveryService_DeltaTapConfigsServer) error FetchTapConfigs(context.Context, *v3.DiscoveryRequest) (*v3.DiscoveryResponse, error) }
TapDiscoveryServiceServer is the server API for TapDiscoveryService service.
type TapDiscoveryService_DeltaTapConfigsClient ¶
type TapDiscoveryService_DeltaTapConfigsClient interface { Send(*v3.DeltaDiscoveryRequest) error Recv() (*v3.DeltaDiscoveryResponse, error) grpc.ClientStream }
type TapDiscoveryService_DeltaTapConfigsServer ¶
type TapDiscoveryService_DeltaTapConfigsServer interface { Send(*v3.DeltaDiscoveryResponse) error Recv() (*v3.DeltaDiscoveryRequest, error) grpc.ServerStream }
type TapDiscoveryService_StreamTapConfigsClient ¶
type TapDiscoveryService_StreamTapConfigsClient interface { Send(*v3.DiscoveryRequest) error Recv() (*v3.DiscoveryResponse, error) grpc.ClientStream }
type TapDiscoveryService_StreamTapConfigsServer ¶
type TapDiscoveryService_StreamTapConfigsServer interface { Send(*v3.DiscoveryResponse) error Recv() (*v3.DiscoveryRequest, error) grpc.ServerStream }
type TapResource ¶
type TapResource struct { Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` Config *v4alpha.TapConfig `protobuf:"bytes,2,opt,name=config,proto3" json:"config,omitempty"` // contains filtered or unexported fields }
func (*TapResource) Descriptor
deprecated
func (*TapResource) Descriptor() ([]byte, []int)
Deprecated: Use TapResource.ProtoReflect.Descriptor instead.
func (*TapResource) GetConfig ¶
func (x *TapResource) GetConfig() *v4alpha.TapConfig
func (*TapResource) GetName ¶
func (x *TapResource) GetName() string
func (*TapResource) ProtoMessage ¶
func (*TapResource) ProtoMessage()
func (*TapResource) ProtoReflect ¶
func (x *TapResource) ProtoReflect() protoreflect.Message
func (*TapResource) Reset ¶
func (x *TapResource) Reset()
func (*TapResource) String ¶
func (x *TapResource) String() string
func (*TapResource) Validate ¶
func (m *TapResource) Validate() error
Validate checks the field values on TapResource with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.
type TapResourceValidationError ¶
type TapResourceValidationError struct {
// contains filtered or unexported fields
}
TapResourceValidationError is the validation error returned by TapResource.Validate if the designated constraints aren't met.
func (TapResourceValidationError) Cause ¶
func (e TapResourceValidationError) Cause() error
Cause function returns cause value.
func (TapResourceValidationError) Error ¶
func (e TapResourceValidationError) Error() string
Error satisfies the builtin error interface
func (TapResourceValidationError) ErrorName ¶
func (e TapResourceValidationError) ErrorName() string
ErrorName returns error name.
func (TapResourceValidationError) Field ¶
func (e TapResourceValidationError) Field() string
Field function returns field value.
func (TapResourceValidationError) Key ¶
func (e TapResourceValidationError) Key() bool
Key function returns key value.
func (TapResourceValidationError) Reason ¶
func (e TapResourceValidationError) Reason() string
Reason function returns reason value.
type TapSinkServiceClient ¶
type TapSinkServiceClient interface {
StreamTaps(ctx context.Context, opts ...grpc.CallOption) (TapSinkService_StreamTapsClient, error)
}
TapSinkServiceClient is the client API for TapSinkService service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.
func NewTapSinkServiceClient ¶
func NewTapSinkServiceClient(cc grpc.ClientConnInterface) TapSinkServiceClient
type TapSinkServiceServer ¶
type TapSinkServiceServer interface {
StreamTaps(TapSinkService_StreamTapsServer) error
}
TapSinkServiceServer is the server API for TapSinkService service.
type TapSinkService_StreamTapsClient ¶
type TapSinkService_StreamTapsClient interface { Send(*StreamTapsRequest) error CloseAndRecv() (*StreamTapsResponse, error) grpc.ClientStream }
type TapSinkService_StreamTapsServer ¶
type TapSinkService_StreamTapsServer interface { SendAndClose(*StreamTapsResponse) error Recv() (*StreamTapsRequest, error) grpc.ServerStream }
type UnimplementedTapDiscoveryServiceServer ¶
type UnimplementedTapDiscoveryServiceServer struct { }
UnimplementedTapDiscoveryServiceServer can be embedded to have forward compatible implementations.
func (*UnimplementedTapDiscoveryServiceServer) DeltaTapConfigs ¶
func (*UnimplementedTapDiscoveryServiceServer) DeltaTapConfigs(TapDiscoveryService_DeltaTapConfigsServer) error
func (*UnimplementedTapDiscoveryServiceServer) FetchTapConfigs ¶
func (*UnimplementedTapDiscoveryServiceServer) FetchTapConfigs(context.Context, *v3.DiscoveryRequest) (*v3.DiscoveryResponse, error)
func (*UnimplementedTapDiscoveryServiceServer) StreamTapConfigs ¶
func (*UnimplementedTapDiscoveryServiceServer) StreamTapConfigs(TapDiscoveryService_StreamTapConfigsServer) error
type UnimplementedTapSinkServiceServer ¶
type UnimplementedTapSinkServiceServer struct { }
UnimplementedTapSinkServiceServer can be embedded to have forward compatible implementations.
func (*UnimplementedTapSinkServiceServer) StreamTaps ¶
func (*UnimplementedTapSinkServiceServer) StreamTaps(TapSinkService_StreamTapsServer) error