event_reportingv3

Documentation

Index

• Variables
• type StreamEventsRequest
  • func (x *StreamEventsRequest) ClearIdentifier()
  • func (x *StreamEventsRequest) GetEvents() []*anypb.Any
  • func (x *StreamEventsRequest) GetIdentifier() *StreamEventsRequest_Identifier
  • func (x *StreamEventsRequest) HasIdentifier() bool
  • func (*StreamEventsRequest) ProtoMessage()
  • func (x *StreamEventsRequest) ProtoReflect() protoreflect.Message
  • func (x *StreamEventsRequest) Reset()
  • func (x *StreamEventsRequest) SetEvents(v []*anypb.Any)
  • func (x *StreamEventsRequest) SetIdentifier(v *StreamEventsRequest_Identifier)
  • func (x *StreamEventsRequest) String() string
• type StreamEventsRequest_Identifier
  • func (x *StreamEventsRequest_Identifier) ClearNode()
  • func (x *StreamEventsRequest_Identifier) GetNode() *v3.Node
  • func (x *StreamEventsRequest_Identifier) HasNode() bool
  • func (*StreamEventsRequest_Identifier) ProtoMessage()
  • func (x *StreamEventsRequest_Identifier) ProtoReflect() protoreflect.Message
  • func (x *StreamEventsRequest_Identifier) Reset()
  • func (x *StreamEventsRequest_Identifier) SetNode(v *v3.Node)
  • func (x *StreamEventsRequest_Identifier) String() string
• type StreamEventsRequest_Identifier_builder
  • func (b0 StreamEventsRequest_Identifier_builder) Build() *StreamEventsRequest_Identifier
• type StreamEventsRequest_builder
  • func (b0 StreamEventsRequest_builder) Build() *StreamEventsRequest
• type StreamEventsResponse
  • func (*StreamEventsResponse) ProtoMessage()
  • func (x *StreamEventsResponse) ProtoReflect() protoreflect.Message
  • func (x *StreamEventsResponse) Reset()
  • func (x *StreamEventsResponse) String() string
• type StreamEventsResponse_builder
  • func (b0 StreamEventsResponse_builder) Build() *StreamEventsResponse

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) ClearIdentifier

func (x *StreamEventsRequest) ClearIdentifier()

func (*StreamEventsRequest) GetEvents

func (x *StreamEventsRequest) GetEvents() []*anypb.Any

func (*StreamEventsRequest) GetIdentifier

func (x *StreamEventsRequest) GetIdentifier() *StreamEventsRequest_Identifier

func (*StreamEventsRequest) HasIdentifier

func (x *StreamEventsRequest) HasIdentifier() bool

func (*StreamEventsRequest) ProtoMessage

func (*StreamEventsRequest) ProtoMessage()

func (*StreamEventsRequest) ProtoReflect

func (x *StreamEventsRequest) ProtoReflect() protoreflect.Message

func (*StreamEventsRequest) Reset

func (x *StreamEventsRequest) Reset()

func (*StreamEventsRequest) SetEvents

func (x *StreamEventsRequest) SetEvents(v []*anypb.Any)

func (*StreamEventsRequest) SetIdentifier

func (x *StreamEventsRequest) SetIdentifier(v *StreamEventsRequest_Identifier)

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) ClearNode

func (x *StreamEventsRequest_Identifier) ClearNode()

func (*StreamEventsRequest_Identifier) GetNode

func (x *StreamEventsRequest_Identifier) GetNode() *v3.Node

func (*StreamEventsRequest_Identifier) HasNode

func (x *StreamEventsRequest_Identifier) HasNode() bool

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) SetNode

func (x *StreamEventsRequest_Identifier) SetNode(v *v3.Node)

func (*StreamEventsRequest_Identifier) String

func (x *StreamEventsRequest_Identifier) String() string

type StreamEventsRequest_Identifier_builder

type StreamEventsRequest_Identifier_builder struct {

	// The node sending the event messages over the stream.
	Node *v3.Node
	// contains filtered or unexported fields
}

func (StreamEventsRequest_Identifier_builder) Build

func (b0 StreamEventsRequest_Identifier_builder) Build() *StreamEventsRequest_Identifier

type StreamEventsRequest_builder

type StreamEventsRequest_builder 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
	// 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
	// contains filtered or unexported fields
}

func (StreamEventsRequest_builder) Build

func (b0 StreamEventsRequest_builder) Build() *StreamEventsRequest

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) 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

type StreamEventsResponse_builder

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

func (StreamEventsResponse_builder) Build

func (b0 StreamEventsResponse_builder) Build() *StreamEventsResponse