Documentation ¶
Index ¶
- Variables
- func RegisterEventReportingServiceServer(s *grpc.Server, srv EventReportingServiceServer)
- type EventReportingServiceClient
- type EventReportingServiceServer
- type EventReportingService_StreamEventsClient
- type EventReportingService_StreamEventsServer
- type StreamEventsRequest
- func (*StreamEventsRequest) Descriptor() ([]byte, []int)deprecated
- func (x *StreamEventsRequest) GetEvents() []*any.Any
- func (x *StreamEventsRequest) GetIdentifier() *StreamEventsRequest_Identifier
- func (*StreamEventsRequest) ProtoMessage()
- func (x *StreamEventsRequest) ProtoReflect() protoreflect.Message
- func (x *StreamEventsRequest) Reset()
- func (x *StreamEventsRequest) String() string
- func (m *StreamEventsRequest) Validate() error
- type StreamEventsRequestValidationError
- func (e StreamEventsRequestValidationError) Cause() error
- func (e StreamEventsRequestValidationError) Error() string
- func (e StreamEventsRequestValidationError) ErrorName() string
- func (e StreamEventsRequestValidationError) Field() string
- func (e StreamEventsRequestValidationError) Key() bool
- func (e StreamEventsRequestValidationError) Reason() string
- type StreamEventsRequest_Identifier
- func (*StreamEventsRequest_Identifier) Descriptor() ([]byte, []int)deprecated
- func (x *StreamEventsRequest_Identifier) GetNode() *v4alpha.Node
- func (*StreamEventsRequest_Identifier) ProtoMessage()
- func (x *StreamEventsRequest_Identifier) ProtoReflect() protoreflect.Message
- func (x *StreamEventsRequest_Identifier) Reset()
- func (x *StreamEventsRequest_Identifier) String() string
- func (m *StreamEventsRequest_Identifier) Validate() error
- type StreamEventsRequest_IdentifierValidationError
- func (e StreamEventsRequest_IdentifierValidationError) Cause() error
- func (e StreamEventsRequest_IdentifierValidationError) Error() string
- func (e StreamEventsRequest_IdentifierValidationError) ErrorName() string
- func (e StreamEventsRequest_IdentifierValidationError) Field() string
- func (e StreamEventsRequest_IdentifierValidationError) Key() bool
- func (e StreamEventsRequest_IdentifierValidationError) Reason() string
- type StreamEventsResponse
- func (*StreamEventsResponse) Descriptor() ([]byte, []int)deprecated
- func (*StreamEventsResponse) ProtoMessage()
- func (x *StreamEventsResponse) ProtoReflect() protoreflect.Message
- func (x *StreamEventsResponse) Reset()
- func (x *StreamEventsResponse) String() string
- func (m *StreamEventsResponse) Validate() error
- type StreamEventsResponseValidationError
- func (e StreamEventsResponseValidationError) Cause() error
- func (e StreamEventsResponseValidationError) Error() string
- func (e StreamEventsResponseValidationError) ErrorName() string
- func (e StreamEventsResponseValidationError) Field() string
- func (e StreamEventsResponseValidationError) Key() bool
- func (e StreamEventsResponseValidationError) Reason() string
- type UnimplementedEventReportingServiceServer
Constants ¶
This section is empty.
Variables ¶
var File_envoy_service_event_reporting_v4alpha_event_reporting_service_proto protoreflect.FileDescriptor
Functions ¶
func RegisterEventReportingServiceServer ¶
func RegisterEventReportingServiceServer(s *grpc.Server, srv EventReportingServiceServer)
Types ¶
type EventReportingServiceClient ¶
type EventReportingServiceClient interface {
StreamEvents(ctx context.Context, opts ...grpc.CallOption) (EventReportingService_StreamEventsClient, error)
}
EventReportingServiceClient is the client API for EventReportingService service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.
func NewEventReportingServiceClient ¶
func NewEventReportingServiceClient(cc grpc.ClientConnInterface) EventReportingServiceClient
type EventReportingServiceServer ¶
type EventReportingServiceServer interface {
StreamEvents(EventReportingService_StreamEventsServer) error
}
EventReportingServiceServer is the server API for EventReportingService service.
type EventReportingService_StreamEventsClient ¶
type EventReportingService_StreamEventsClient interface { Send(*StreamEventsRequest) error Recv() (*StreamEventsResponse, error) grpc.ClientStream }
type EventReportingService_StreamEventsServer ¶
type EventReportingService_StreamEventsServer interface { Send(*StreamEventsResponse) error Recv() (*StreamEventsRequest, error) grpc.ServerStream }
type StreamEventsRequest ¶
type StreamEventsRequest struct { Identifier *StreamEventsRequest_Identifier `protobuf:"bytes,1,opt,name=identifier,proto3" json:"identifier,omitempty"` Events []*any.Any `protobuf:"bytes,2,rep,name=events,proto3" json:"events,omitempty"` // contains filtered or unexported fields }
func (*StreamEventsRequest) Descriptor
deprecated
func (*StreamEventsRequest) Descriptor() ([]byte, []int)
Deprecated: Use StreamEventsRequest.ProtoReflect.Descriptor instead.
func (*StreamEventsRequest) GetEvents ¶
func (x *StreamEventsRequest) GetEvents() []*any.Any
func (*StreamEventsRequest) GetIdentifier ¶
func (x *StreamEventsRequest) GetIdentifier() *StreamEventsRequest_Identifier
func (*StreamEventsRequest) ProtoMessage ¶
func (*StreamEventsRequest) ProtoMessage()
func (*StreamEventsRequest) ProtoReflect ¶
func (x *StreamEventsRequest) ProtoReflect() protoreflect.Message
func (*StreamEventsRequest) Reset ¶
func (x *StreamEventsRequest) Reset()
func (*StreamEventsRequest) String ¶
func (x *StreamEventsRequest) String() string
func (*StreamEventsRequest) Validate ¶
func (m *StreamEventsRequest) Validate() error
Validate checks the field values on StreamEventsRequest with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.
type StreamEventsRequestValidationError ¶
type StreamEventsRequestValidationError struct {
// contains filtered or unexported fields
}
StreamEventsRequestValidationError is the validation error returned by StreamEventsRequest.Validate if the designated constraints aren't met.
func (StreamEventsRequestValidationError) Cause ¶
func (e StreamEventsRequestValidationError) Cause() error
Cause function returns cause value.
func (StreamEventsRequestValidationError) Error ¶
func (e StreamEventsRequestValidationError) Error() string
Error satisfies the builtin error interface
func (StreamEventsRequestValidationError) ErrorName ¶
func (e StreamEventsRequestValidationError) ErrorName() string
ErrorName returns error name.
func (StreamEventsRequestValidationError) Field ¶
func (e StreamEventsRequestValidationError) Field() string
Field function returns field value.
func (StreamEventsRequestValidationError) Key ¶
func (e StreamEventsRequestValidationError) Key() bool
Key function returns key value.
func (StreamEventsRequestValidationError) Reason ¶
func (e StreamEventsRequestValidationError) Reason() string
Reason function returns reason value.
type StreamEventsRequest_Identifier ¶
type StreamEventsRequest_Identifier struct { Node *v4alpha.Node `protobuf:"bytes,1,opt,name=node,proto3" json:"node,omitempty"` // contains filtered or unexported fields }
func (*StreamEventsRequest_Identifier) Descriptor
deprecated
func (*StreamEventsRequest_Identifier) Descriptor() ([]byte, []int)
Deprecated: Use StreamEventsRequest_Identifier.ProtoReflect.Descriptor instead.
func (*StreamEventsRequest_Identifier) GetNode ¶
func (x *StreamEventsRequest_Identifier) GetNode() *v4alpha.Node
func (*StreamEventsRequest_Identifier) ProtoMessage ¶
func (*StreamEventsRequest_Identifier) ProtoMessage()
func (*StreamEventsRequest_Identifier) ProtoReflect ¶
func (x *StreamEventsRequest_Identifier) ProtoReflect() protoreflect.Message
func (*StreamEventsRequest_Identifier) Reset ¶
func (x *StreamEventsRequest_Identifier) Reset()
func (*StreamEventsRequest_Identifier) String ¶
func (x *StreamEventsRequest_Identifier) String() string
func (*StreamEventsRequest_Identifier) Validate ¶
func (m *StreamEventsRequest_Identifier) Validate() error
Validate checks the field values on StreamEventsRequest_Identifier with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.
type StreamEventsRequest_IdentifierValidationError ¶
type StreamEventsRequest_IdentifierValidationError struct {
// contains filtered or unexported fields
}
StreamEventsRequest_IdentifierValidationError is the validation error returned by StreamEventsRequest_Identifier.Validate if the designated constraints aren't met.
func (StreamEventsRequest_IdentifierValidationError) Cause ¶
func (e StreamEventsRequest_IdentifierValidationError) Cause() error
Cause function returns cause value.
func (StreamEventsRequest_IdentifierValidationError) Error ¶
func (e StreamEventsRequest_IdentifierValidationError) Error() string
Error satisfies the builtin error interface
func (StreamEventsRequest_IdentifierValidationError) ErrorName ¶
func (e StreamEventsRequest_IdentifierValidationError) ErrorName() string
ErrorName returns error name.
func (StreamEventsRequest_IdentifierValidationError) Field ¶
func (e StreamEventsRequest_IdentifierValidationError) Field() string
Field function returns field value.
func (StreamEventsRequest_IdentifierValidationError) Key ¶
func (e StreamEventsRequest_IdentifierValidationError) Key() bool
Key function returns key value.
func (StreamEventsRequest_IdentifierValidationError) Reason ¶
func (e StreamEventsRequest_IdentifierValidationError) Reason() string
Reason function returns reason value.
type StreamEventsResponse ¶
type StreamEventsResponse struct {
// contains filtered or unexported fields
}
func (*StreamEventsResponse) Descriptor
deprecated
func (*StreamEventsResponse) Descriptor() ([]byte, []int)
Deprecated: Use StreamEventsResponse.ProtoReflect.Descriptor instead.
func (*StreamEventsResponse) ProtoMessage ¶
func (*StreamEventsResponse) ProtoMessage()
func (*StreamEventsResponse) ProtoReflect ¶
func (x *StreamEventsResponse) ProtoReflect() protoreflect.Message
func (*StreamEventsResponse) Reset ¶
func (x *StreamEventsResponse) Reset()
func (*StreamEventsResponse) String ¶
func (x *StreamEventsResponse) String() string
func (*StreamEventsResponse) Validate ¶
func (m *StreamEventsResponse) Validate() error
Validate checks the field values on StreamEventsResponse with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.
type StreamEventsResponseValidationError ¶
type StreamEventsResponseValidationError struct {
// contains filtered or unexported fields
}
StreamEventsResponseValidationError is the validation error returned by StreamEventsResponse.Validate if the designated constraints aren't met.
func (StreamEventsResponseValidationError) Cause ¶
func (e StreamEventsResponseValidationError) Cause() error
Cause function returns cause value.
func (StreamEventsResponseValidationError) Error ¶
func (e StreamEventsResponseValidationError) Error() string
Error satisfies the builtin error interface
func (StreamEventsResponseValidationError) ErrorName ¶
func (e StreamEventsResponseValidationError) ErrorName() string
ErrorName returns error name.
func (StreamEventsResponseValidationError) Field ¶
func (e StreamEventsResponseValidationError) Field() string
Field function returns field value.
func (StreamEventsResponseValidationError) Key ¶
func (e StreamEventsResponseValidationError) Key() bool
Key function returns key value.
func (StreamEventsResponseValidationError) Reason ¶
func (e StreamEventsResponseValidationError) Reason() string
Reason function returns reason value.
type UnimplementedEventReportingServiceServer ¶
type UnimplementedEventReportingServiceServer struct { }
UnimplementedEventReportingServiceServer can be embedded to have forward compatible implementations.
func (*UnimplementedEventReportingServiceServer) StreamEvents ¶
func (*UnimplementedEventReportingServiceServer) StreamEvents(EventReportingService_StreamEventsServer) error