event_reportingv3

Documentation

Index

• Variables
• type StreamEventsRequest
  • func (*StreamEventsRequest) Descriptor() ([]byte, []int)
  • func (x *StreamEventsRequest) GetEvents() []*anypb.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
• type StreamEventsRequest_Identifier
  • func (*StreamEventsRequest_Identifier) Descriptor() ([]byte, []int)
  • func (x *StreamEventsRequest_Identifier) GetNode() *v3.Node
  • func (*StreamEventsRequest_Identifier) ProtoMessage()
  • func (x *StreamEventsRequest_Identifier) ProtoReflect() protoreflect.Message
  • func (x *StreamEventsRequest_Identifier) Reset()
  • func (x *StreamEventsRequest_Identifier) String() string
• type StreamEventsResponse
  • func (*StreamEventsResponse) Descriptor() ([]byte, []int)
  • func (*StreamEventsResponse) ProtoMessage()
  • func (x *StreamEventsResponse) ProtoReflect() protoreflect.Message
  • func (x *StreamEventsResponse) Reset()
  • func (x *StreamEventsResponse) String() string

Variables

var File_envoy_service_event_reporting_v3_event_reporting_service_proto protoreflect.FileDescriptor

Types

type StreamEventsRequest

type StreamEventsRequest struct {

	// Identifier data that will only be sent in the first message on the stream. This is effectively
	// structured metadata and is a performance optimization.
	Identifier *StreamEventsRequest_Identifier `protobuf:"bytes,1,opt,name=identifier,proto3" json:"identifier,omitempty"`
	// Batch of events. When the stream is already active, it will be the events occurred
	// since the last message had been sent. If the server receives unknown event type, it should
	// silently ignore it.
	//
	// The following events are supported:
	//
	// * :ref:`HealthCheckEvent <envoy_v3_api_msg_data.core.v3.HealthCheckEvent>`
	// * :ref:`OutlierDetectionEvent <envoy_v3_api_msg_data.cluster.v3.OutlierDetectionEvent>`
	Events []*anypb.Any `protobuf:"bytes,2,rep,name=events,proto3" json:"events,omitempty"`
	// contains filtered or unexported fields
}

[#not-implemented-hide:] An events envoy sends to the management server.

func (*StreamEventsRequest) Descriptor

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

Deprecated: Use StreamEventsRequest.ProtoReflect.Descriptor instead.

func (*StreamEventsRequest) GetEvents

func (x *StreamEventsRequest) GetEvents() []*anypb.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

type StreamEventsRequest_Identifier

type StreamEventsRequest_Identifier struct {

	// The node sending the event messages over the stream.
	Node *v3.Node `protobuf:"bytes,1,opt,name=node,proto3" json:"node,omitempty"`
	// contains filtered or unexported fields
}

func (*StreamEventsRequest_Identifier) Descriptor

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

Deprecated: Use StreamEventsRequest_Identifier.ProtoReflect.Descriptor instead.

func (*StreamEventsRequest_Identifier) GetNode

func (x *StreamEventsRequest_Identifier) GetNode() *v3.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

type StreamEventsResponse

type StreamEventsResponse struct {
	// contains filtered or unexported fields
}

[#not-implemented-hide:] The management server may send envoy a StreamEventsResponse to tell which events the server is interested in. In future, with aggregated event reporting service, this message will contain, for example, clusters the envoy should send events for, or event types the server wants to process.

func (*StreamEventsResponse) Descriptor

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