Documentation ¶
Index ¶
- Variables
- func RegisterAggregatedDiscoveryServiceServer(s *grpc.Server, srv AggregatedDiscoveryServiceServer)
- type AdsDummy
- type AdsDummyValidationError
- type AggregatedDiscoveryServiceClient
- type AggregatedDiscoveryServiceServer
- type AggregatedDiscoveryService_DeltaAggregatedResourcesClient
- type AggregatedDiscoveryService_DeltaAggregatedResourcesServer
- type AggregatedDiscoveryService_StreamAggregatedResourcesClient
- type AggregatedDiscoveryService_StreamAggregatedResourcesServer
- type DeltaDiscoveryRequest
- func (*DeltaDiscoveryRequest) Descriptor() ([]byte, []int)deprecated
- func (x *DeltaDiscoveryRequest) GetErrorDetail() *status.Status
- func (x *DeltaDiscoveryRequest) GetInitialResourceVersions() map[string]string
- func (x *DeltaDiscoveryRequest) GetNode() *v4alpha.Node
- func (x *DeltaDiscoveryRequest) GetResourceNamesSubscribe() []string
- func (x *DeltaDiscoveryRequest) GetResourceNamesUnsubscribe() []string
- func (x *DeltaDiscoveryRequest) GetResponseNonce() string
- func (x *DeltaDiscoveryRequest) GetTypeUrl() string
- func (x *DeltaDiscoveryRequest) GetUdpaResourcesSubscribe() []*v1.ResourceLocator
- func (x *DeltaDiscoveryRequest) GetUdpaResourcesUnsubscribe() []*v1.ResourceLocator
- func (*DeltaDiscoveryRequest) ProtoMessage()
- func (x *DeltaDiscoveryRequest) ProtoReflect() protoreflect.Message
- func (x *DeltaDiscoveryRequest) Reset()
- func (x *DeltaDiscoveryRequest) String() string
- func (m *DeltaDiscoveryRequest) Validate() error
- type DeltaDiscoveryRequestValidationError
- func (e DeltaDiscoveryRequestValidationError) Cause() error
- func (e DeltaDiscoveryRequestValidationError) Error() string
- func (e DeltaDiscoveryRequestValidationError) ErrorName() string
- func (e DeltaDiscoveryRequestValidationError) Field() string
- func (e DeltaDiscoveryRequestValidationError) Key() bool
- func (e DeltaDiscoveryRequestValidationError) Reason() string
- type DeltaDiscoveryResponse
- func (*DeltaDiscoveryResponse) Descriptor() ([]byte, []int)deprecated
- func (x *DeltaDiscoveryResponse) GetNonce() string
- func (x *DeltaDiscoveryResponse) GetRemovedResources() []string
- func (x *DeltaDiscoveryResponse) GetResources() []*Resource
- func (x *DeltaDiscoveryResponse) GetSystemVersionInfo() string
- func (x *DeltaDiscoveryResponse) GetTypeUrl() string
- func (x *DeltaDiscoveryResponse) GetUdpaRemovedResources() []*v1.ResourceName
- func (*DeltaDiscoveryResponse) ProtoMessage()
- func (x *DeltaDiscoveryResponse) ProtoReflect() protoreflect.Message
- func (x *DeltaDiscoveryResponse) Reset()
- func (x *DeltaDiscoveryResponse) String() string
- func (m *DeltaDiscoveryResponse) Validate() error
- type DeltaDiscoveryResponseValidationError
- func (e DeltaDiscoveryResponseValidationError) Cause() error
- func (e DeltaDiscoveryResponseValidationError) Error() string
- func (e DeltaDiscoveryResponseValidationError) ErrorName() string
- func (e DeltaDiscoveryResponseValidationError) Field() string
- func (e DeltaDiscoveryResponseValidationError) Key() bool
- func (e DeltaDiscoveryResponseValidationError) Reason() string
- type DiscoveryRequest
- func (*DiscoveryRequest) Descriptor() ([]byte, []int)deprecated
- func (x *DiscoveryRequest) GetErrorDetail() *status.Status
- func (x *DiscoveryRequest) GetNode() *v4alpha.Node
- func (x *DiscoveryRequest) GetResourceNames() []string
- func (x *DiscoveryRequest) GetResponseNonce() string
- func (x *DiscoveryRequest) GetTypeUrl() string
- func (x *DiscoveryRequest) GetVersionInfo() string
- func (*DiscoveryRequest) ProtoMessage()
- func (x *DiscoveryRequest) ProtoReflect() protoreflect.Message
- func (x *DiscoveryRequest) Reset()
- func (x *DiscoveryRequest) String() string
- func (m *DiscoveryRequest) Validate() error
- type DiscoveryRequestValidationError
- func (e DiscoveryRequestValidationError) Cause() error
- func (e DiscoveryRequestValidationError) Error() string
- func (e DiscoveryRequestValidationError) ErrorName() string
- func (e DiscoveryRequestValidationError) Field() string
- func (e DiscoveryRequestValidationError) Key() bool
- func (e DiscoveryRequestValidationError) Reason() string
- type DiscoveryResponse
- func (*DiscoveryResponse) Descriptor() ([]byte, []int)deprecated
- func (x *DiscoveryResponse) GetCanary() bool
- func (x *DiscoveryResponse) GetControlPlane() *v4alpha.ControlPlane
- func (x *DiscoveryResponse) GetNonce() string
- func (x *DiscoveryResponse) GetResources() []*any.Any
- func (x *DiscoveryResponse) GetTypeUrl() string
- func (x *DiscoveryResponse) GetVersionInfo() string
- func (*DiscoveryResponse) ProtoMessage()
- func (x *DiscoveryResponse) ProtoReflect() protoreflect.Message
- func (x *DiscoveryResponse) Reset()
- func (x *DiscoveryResponse) String() string
- func (m *DiscoveryResponse) Validate() error
- type DiscoveryResponseValidationError
- func (e DiscoveryResponseValidationError) Cause() error
- func (e DiscoveryResponseValidationError) Error() string
- func (e DiscoveryResponseValidationError) ErrorName() string
- func (e DiscoveryResponseValidationError) Field() string
- func (e DiscoveryResponseValidationError) Key() bool
- func (e DiscoveryResponseValidationError) Reason() string
- type Resource
- func (*Resource) Descriptor() ([]byte, []int)deprecated
- func (x *Resource) GetAliases() []string
- func (x *Resource) GetName() string
- func (m *Resource) GetNameSpecifier() isResource_NameSpecifier
- func (x *Resource) GetResource() *any.Any
- func (x *Resource) GetUdpaResourceName() *v1.ResourceName
- func (x *Resource) GetVersion() string
- func (*Resource) ProtoMessage()
- func (x *Resource) ProtoReflect() protoreflect.Message
- func (x *Resource) Reset()
- func (x *Resource) String() string
- func (m *Resource) Validate() error
- type ResourceValidationError
- type Resource_Name
- type Resource_UdpaResourceName
- type UnimplementedAggregatedDiscoveryServiceServer
Constants ¶
This section is empty.
Variables ¶
var File_envoy_service_discovery_v4alpha_ads_proto protoreflect.FileDescriptor
var File_envoy_service_discovery_v4alpha_discovery_proto protoreflect.FileDescriptor
Functions ¶
func RegisterAggregatedDiscoveryServiceServer ¶
func RegisterAggregatedDiscoveryServiceServer(s *grpc.Server, srv AggregatedDiscoveryServiceServer)
Types ¶
type AdsDummy ¶
type AdsDummy struct {
// contains filtered or unexported fields
}
[#not-implemented-hide:] Not configuration. Workaround c++ protobuf issue with importing services: https://github.com/google/protobuf/issues/4221
func (*AdsDummy) Descriptor
deprecated
func (*AdsDummy) ProtoMessage ¶
func (*AdsDummy) ProtoMessage()
func (*AdsDummy) ProtoReflect ¶
func (x *AdsDummy) ProtoReflect() protoreflect.Message
type AdsDummyValidationError ¶
type AdsDummyValidationError struct {
// contains filtered or unexported fields
}
AdsDummyValidationError is the validation error returned by AdsDummy.Validate if the designated constraints aren't met.
func (AdsDummyValidationError) Cause ¶
func (e AdsDummyValidationError) Cause() error
Cause function returns cause value.
func (AdsDummyValidationError) Error ¶
func (e AdsDummyValidationError) Error() string
Error satisfies the builtin error interface
func (AdsDummyValidationError) ErrorName ¶
func (e AdsDummyValidationError) ErrorName() string
ErrorName returns error name.
func (AdsDummyValidationError) Field ¶
func (e AdsDummyValidationError) Field() string
Field function returns field value.
func (AdsDummyValidationError) Key ¶
func (e AdsDummyValidationError) Key() bool
Key function returns key value.
func (AdsDummyValidationError) Reason ¶
func (e AdsDummyValidationError) Reason() string
Reason function returns reason value.
type AggregatedDiscoveryServiceClient ¶
type AggregatedDiscoveryServiceClient interface { // This is a gRPC-only API. StreamAggregatedResources(ctx context.Context, opts ...grpc.CallOption) (AggregatedDiscoveryService_StreamAggregatedResourcesClient, error) DeltaAggregatedResources(ctx context.Context, opts ...grpc.CallOption) (AggregatedDiscoveryService_DeltaAggregatedResourcesClient, error) }
AggregatedDiscoveryServiceClient is the client API for AggregatedDiscoveryService service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.
func NewAggregatedDiscoveryServiceClient ¶
func NewAggregatedDiscoveryServiceClient(cc grpc.ClientConnInterface) AggregatedDiscoveryServiceClient
type AggregatedDiscoveryServiceServer ¶
type AggregatedDiscoveryServiceServer interface { // This is a gRPC-only API. StreamAggregatedResources(AggregatedDiscoveryService_StreamAggregatedResourcesServer) error DeltaAggregatedResources(AggregatedDiscoveryService_DeltaAggregatedResourcesServer) error }
AggregatedDiscoveryServiceServer is the server API for AggregatedDiscoveryService service.
type AggregatedDiscoveryService_DeltaAggregatedResourcesClient ¶
type AggregatedDiscoveryService_DeltaAggregatedResourcesClient interface { Send(*DeltaDiscoveryRequest) error Recv() (*DeltaDiscoveryResponse, error) grpc.ClientStream }
type AggregatedDiscoveryService_DeltaAggregatedResourcesServer ¶
type AggregatedDiscoveryService_DeltaAggregatedResourcesServer interface { Send(*DeltaDiscoveryResponse) error Recv() (*DeltaDiscoveryRequest, error) grpc.ServerStream }
type AggregatedDiscoveryService_StreamAggregatedResourcesClient ¶
type AggregatedDiscoveryService_StreamAggregatedResourcesClient interface { Send(*DiscoveryRequest) error Recv() (*DiscoveryResponse, error) grpc.ClientStream }
type AggregatedDiscoveryService_StreamAggregatedResourcesServer ¶
type AggregatedDiscoveryService_StreamAggregatedResourcesServer interface { Send(*DiscoveryResponse) error Recv() (*DiscoveryRequest, error) grpc.ServerStream }
type DeltaDiscoveryRequest ¶
type DeltaDiscoveryRequest struct { // The node making the request. Node *v4alpha.Node `protobuf:"bytes,1,opt,name=node,proto3" json:"node,omitempty"` // Type of the resource that is being requested, e.g. // "type.googleapis.com/envoy.api.v2.ClusterLoadAssignment". This does not need to be set if // resources are only referenced via *udpa_resource_subscribe* and // *udpa_resources_unsubscribe*. TypeUrl string `protobuf:"bytes,2,opt,name=type_url,json=typeUrl,proto3" json:"type_url,omitempty"` // DeltaDiscoveryRequests allow the client to add or remove individual // resources to the set of tracked resources in the context of a stream. // All resource names in the resource_names_subscribe list are added to the // set of tracked resources and all resource names in the resource_names_unsubscribe // list are removed from the set of tracked resources. // // *Unlike* state-of-the-world xDS, an empty resource_names_subscribe or // resource_names_unsubscribe list simply means that no resources are to be // added or removed to the resource list. // *Like* state-of-the-world xDS, the server must send updates for all tracked // resources, but can also send updates for resources the client has not subscribed to. // // NOTE: the server must respond with all resources listed in resource_names_subscribe, // even if it believes the client has the most recent version of them. The reason: // the client may have dropped them, but then regained interest before it had a chance // to send the unsubscribe message. See DeltaSubscriptionStateTest.RemoveThenAdd. // // These two fields can be set in any DeltaDiscoveryRequest, including ACKs // and initial_resource_versions. // // A list of Resource names to add to the list of tracked resources. ResourceNamesSubscribe []string `` /* 129-byte string literal not displayed */ // As with *resource_names_subscribe* but used when subscribing to resources indicated // by a *udpa.core.v1.ResourceLocator*. The directives in the resource locator // are ignored and the context parameters are matched with // *context_param_specifier* specific semantics. // [#not-implemented-hide:] UdpaResourcesSubscribe []*v1.ResourceLocator `` /* 129-byte string literal not displayed */ // A list of Resource names to remove from the list of tracked resources. ResourceNamesUnsubscribe []string `` /* 135-byte string literal not displayed */ // As with *resource_names_unsubscribe* but used when unsubscribing to resources indicated by a // *udpa.core.v1.ResourceLocator*. This must match a previously subscribed // resource locator provided in *udpa_resources_subscribe*. // [#not-implemented-hide:] UdpaResourcesUnsubscribe []*v1.ResourceLocator `` /* 135-byte string literal not displayed */ // Informs the server of the versions of the resources the xDS client knows of, to enable the // client to continue the same logical xDS session even in the face of gRPC stream reconnection. // It will not be populated: [1] in the very first stream of a session, since the client will // not yet have any resources, [2] in any message after the first in a stream (for a given // type_url), since the server will already be correctly tracking the client's state. // (In ADS, the first message *of each type_url* of a reconnected stream populates this map.) // The map's keys are names of xDS resources known to the xDS client. // The map's values are opaque resource versions. InitialResourceVersions map[string]string `` /* 220-byte string literal not displayed */ // When the DeltaDiscoveryRequest is a ACK or NACK message in response // to a previous DeltaDiscoveryResponse, the response_nonce must be the // nonce in the DeltaDiscoveryResponse. // Otherwise (unlike in DiscoveryRequest) response_nonce must be omitted. ResponseNonce string `protobuf:"bytes,6,opt,name=response_nonce,json=responseNonce,proto3" json:"response_nonce,omitempty"` // This is populated when the previous :ref:`DiscoveryResponse <envoy_api_msg_service.discovery.v4alpha.DiscoveryResponse>` // failed to update configuration. The *message* field in *error_details* // provides the Envoy internal exception related to the failure. ErrorDetail *status.Status `protobuf:"bytes,7,opt,name=error_detail,json=errorDetail,proto3" json:"error_detail,omitempty"` // contains filtered or unexported fields }
DeltaDiscoveryRequest and DeltaDiscoveryResponse are used in a new gRPC endpoint for Delta xDS.
With Delta xDS, the DeltaDiscoveryResponses do not need to include a full snapshot of the tracked resources. Instead, DeltaDiscoveryResponses are a diff to the state of a xDS client. In Delta XDS there are per-resource versions, which allow tracking state at the resource granularity. An xDS Delta session is always in the context of a gRPC bidirectional stream. This allows the xDS server to keep track of the state of xDS clients connected to it.
In Delta xDS the nonce field is required and used to pair DeltaDiscoveryResponse to a DeltaDiscoveryRequest ACK or NACK. Optionally, a response message level system_version_info is present for debugging purposes only.
DeltaDiscoveryRequest plays two independent roles. Any DeltaDiscoveryRequest can be either or both of: [1] informing the server of what resources the client has gained/lost interest in (using resource_names_subscribe and resource_names_unsubscribe), or [2] (N)ACKing an earlier resource update from the server (using response_nonce, with presence of error_detail making it a NACK). Additionally, the first message (for a given type_url) of a reconnected gRPC stream has a third role: informing the server of the resources (and their versions) that the client already possesses, using the initial_resource_versions field.
As with state-of-the-world, when multiple resource types are multiplexed (ADS), all requests/acknowledgments/updates are logically walled off by type_url: a Cluster ACK exists in a completely separate world from a prior Route NACK. In particular, initial_resource_versions being sent at the "start" of every gRPC stream actually entails a message for each type_url, each with its own initial_resource_versions. [#next-free-field: 10]
func (*DeltaDiscoveryRequest) Descriptor
deprecated
func (*DeltaDiscoveryRequest) Descriptor() ([]byte, []int)
Deprecated: Use DeltaDiscoveryRequest.ProtoReflect.Descriptor instead.
func (*DeltaDiscoveryRequest) GetErrorDetail ¶
func (x *DeltaDiscoveryRequest) GetErrorDetail() *status.Status
func (*DeltaDiscoveryRequest) GetInitialResourceVersions ¶
func (x *DeltaDiscoveryRequest) GetInitialResourceVersions() map[string]string
func (*DeltaDiscoveryRequest) GetNode ¶
func (x *DeltaDiscoveryRequest) GetNode() *v4alpha.Node
func (*DeltaDiscoveryRequest) GetResourceNamesSubscribe ¶
func (x *DeltaDiscoveryRequest) GetResourceNamesSubscribe() []string
func (*DeltaDiscoveryRequest) GetResourceNamesUnsubscribe ¶
func (x *DeltaDiscoveryRequest) GetResourceNamesUnsubscribe() []string
func (*DeltaDiscoveryRequest) GetResponseNonce ¶
func (x *DeltaDiscoveryRequest) GetResponseNonce() string
func (*DeltaDiscoveryRequest) GetTypeUrl ¶
func (x *DeltaDiscoveryRequest) GetTypeUrl() string
func (*DeltaDiscoveryRequest) GetUdpaResourcesSubscribe ¶ added in v0.9.10
func (x *DeltaDiscoveryRequest) GetUdpaResourcesSubscribe() []*v1.ResourceLocator
func (*DeltaDiscoveryRequest) GetUdpaResourcesUnsubscribe ¶ added in v0.9.10
func (x *DeltaDiscoveryRequest) GetUdpaResourcesUnsubscribe() []*v1.ResourceLocator
func (*DeltaDiscoveryRequest) ProtoMessage ¶
func (*DeltaDiscoveryRequest) ProtoMessage()
func (*DeltaDiscoveryRequest) ProtoReflect ¶
func (x *DeltaDiscoveryRequest) ProtoReflect() protoreflect.Message
func (*DeltaDiscoveryRequest) Reset ¶
func (x *DeltaDiscoveryRequest) Reset()
func (*DeltaDiscoveryRequest) String ¶
func (x *DeltaDiscoveryRequest) String() string
func (*DeltaDiscoveryRequest) Validate ¶
func (m *DeltaDiscoveryRequest) Validate() error
Validate checks the field values on DeltaDiscoveryRequest with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.
type DeltaDiscoveryRequestValidationError ¶
type DeltaDiscoveryRequestValidationError struct {
// contains filtered or unexported fields
}
DeltaDiscoveryRequestValidationError is the validation error returned by DeltaDiscoveryRequest.Validate if the designated constraints aren't met.
func (DeltaDiscoveryRequestValidationError) Cause ¶
func (e DeltaDiscoveryRequestValidationError) Cause() error
Cause function returns cause value.
func (DeltaDiscoveryRequestValidationError) Error ¶
func (e DeltaDiscoveryRequestValidationError) Error() string
Error satisfies the builtin error interface
func (DeltaDiscoveryRequestValidationError) ErrorName ¶
func (e DeltaDiscoveryRequestValidationError) ErrorName() string
ErrorName returns error name.
func (DeltaDiscoveryRequestValidationError) Field ¶
func (e DeltaDiscoveryRequestValidationError) Field() string
Field function returns field value.
func (DeltaDiscoveryRequestValidationError) Key ¶
func (e DeltaDiscoveryRequestValidationError) Key() bool
Key function returns key value.
func (DeltaDiscoveryRequestValidationError) Reason ¶
func (e DeltaDiscoveryRequestValidationError) Reason() string
Reason function returns reason value.
type DeltaDiscoveryResponse ¶
type DeltaDiscoveryResponse struct { // The version of the response data (used for debugging). SystemVersionInfo string `protobuf:"bytes,1,opt,name=system_version_info,json=systemVersionInfo,proto3" json:"system_version_info,omitempty"` // The response resources. These are typed resources, whose types must match // the type_url field. Resources []*Resource `protobuf:"bytes,2,rep,name=resources,proto3" json:"resources,omitempty"` // Type URL for resources. Identifies the xDS API when muxing over ADS. // Must be consistent with the type_url in the Any within 'resources' if 'resources' is non-empty. // This does not need to be set if *udpa_removed_resources* is used instead of // *removed_resources*. TypeUrl string `protobuf:"bytes,4,opt,name=type_url,json=typeUrl,proto3" json:"type_url,omitempty"` // Resources names of resources that have be deleted and to be removed from the xDS Client. // Removed resources for missing resources can be ignored. RemovedResources []string `protobuf:"bytes,6,rep,name=removed_resources,json=removedResources,proto3" json:"removed_resources,omitempty"` // As with *removed_resources* but used when a removed resource was named in // its *Resource*s with a *udpa.core.v1.ResourceName*. // [#not-implemented-hide:] UdpaRemovedResources []*v1.ResourceName `protobuf:"bytes,7,rep,name=udpa_removed_resources,json=udpaRemovedResources,proto3" json:"udpa_removed_resources,omitempty"` // The nonce provides a way for DeltaDiscoveryRequests to uniquely // reference a DeltaDiscoveryResponse when (N)ACKing. The nonce is required. Nonce string `protobuf:"bytes,5,opt,name=nonce,proto3" json:"nonce,omitempty"` // contains filtered or unexported fields }
[#next-free-field: 8]
func (*DeltaDiscoveryResponse) Descriptor
deprecated
func (*DeltaDiscoveryResponse) Descriptor() ([]byte, []int)
Deprecated: Use DeltaDiscoveryResponse.ProtoReflect.Descriptor instead.
func (*DeltaDiscoveryResponse) GetNonce ¶
func (x *DeltaDiscoveryResponse) GetNonce() string
func (*DeltaDiscoveryResponse) GetRemovedResources ¶
func (x *DeltaDiscoveryResponse) GetRemovedResources() []string
func (*DeltaDiscoveryResponse) GetResources ¶
func (x *DeltaDiscoveryResponse) GetResources() []*Resource
func (*DeltaDiscoveryResponse) GetSystemVersionInfo ¶
func (x *DeltaDiscoveryResponse) GetSystemVersionInfo() string
func (*DeltaDiscoveryResponse) GetTypeUrl ¶
func (x *DeltaDiscoveryResponse) GetTypeUrl() string
func (*DeltaDiscoveryResponse) GetUdpaRemovedResources ¶ added in v0.9.10
func (x *DeltaDiscoveryResponse) GetUdpaRemovedResources() []*v1.ResourceName
func (*DeltaDiscoveryResponse) ProtoMessage ¶
func (*DeltaDiscoveryResponse) ProtoMessage()
func (*DeltaDiscoveryResponse) ProtoReflect ¶
func (x *DeltaDiscoveryResponse) ProtoReflect() protoreflect.Message
func (*DeltaDiscoveryResponse) Reset ¶
func (x *DeltaDiscoveryResponse) Reset()
func (*DeltaDiscoveryResponse) String ¶
func (x *DeltaDiscoveryResponse) String() string
func (*DeltaDiscoveryResponse) Validate ¶
func (m *DeltaDiscoveryResponse) Validate() error
Validate checks the field values on DeltaDiscoveryResponse with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.
type DeltaDiscoveryResponseValidationError ¶
type DeltaDiscoveryResponseValidationError struct {
// contains filtered or unexported fields
}
DeltaDiscoveryResponseValidationError is the validation error returned by DeltaDiscoveryResponse.Validate if the designated constraints aren't met.
func (DeltaDiscoveryResponseValidationError) Cause ¶
func (e DeltaDiscoveryResponseValidationError) Cause() error
Cause function returns cause value.
func (DeltaDiscoveryResponseValidationError) Error ¶
func (e DeltaDiscoveryResponseValidationError) Error() string
Error satisfies the builtin error interface
func (DeltaDiscoveryResponseValidationError) ErrorName ¶
func (e DeltaDiscoveryResponseValidationError) ErrorName() string
ErrorName returns error name.
func (DeltaDiscoveryResponseValidationError) Field ¶
func (e DeltaDiscoveryResponseValidationError) Field() string
Field function returns field value.
func (DeltaDiscoveryResponseValidationError) Key ¶
func (e DeltaDiscoveryResponseValidationError) Key() bool
Key function returns key value.
func (DeltaDiscoveryResponseValidationError) Reason ¶
func (e DeltaDiscoveryResponseValidationError) Reason() string
Reason function returns reason value.
type DiscoveryRequest ¶
type DiscoveryRequest struct { // The version_info provided in the request messages will be the version_info // received with the most recent successfully processed response or empty on // the first request. It is expected that no new request is sent after a // response is received until the Envoy instance is ready to ACK/NACK the new // configuration. ACK/NACK takes place by returning the new API config version // as applied or the previous API config version respectively. Each type_url // (see below) has an independent version associated with it. VersionInfo string `protobuf:"bytes,1,opt,name=version_info,json=versionInfo,proto3" json:"version_info,omitempty"` // The node making the request. Node *v4alpha.Node `protobuf:"bytes,2,opt,name=node,proto3" json:"node,omitempty"` // List of resources to subscribe to, e.g. list of cluster names or a route // configuration name. If this is empty, all resources for the API are // returned. LDS/CDS may have empty resource_names, which will cause all // resources for the Envoy instance to be returned. The LDS and CDS responses // will then imply a number of resources that need to be fetched via EDS/RDS, // which will be explicitly enumerated in resource_names. ResourceNames []string `protobuf:"bytes,3,rep,name=resource_names,json=resourceNames,proto3" json:"resource_names,omitempty"` // Type of the resource that is being requested, e.g. // "type.googleapis.com/envoy.api.v2.ClusterLoadAssignment". This is implicit // in requests made via singleton xDS APIs such as CDS, LDS, etc. but is // required for ADS. TypeUrl string `protobuf:"bytes,4,opt,name=type_url,json=typeUrl,proto3" json:"type_url,omitempty"` // nonce corresponding to DiscoveryResponse being ACK/NACKed. See above // discussion on version_info and the DiscoveryResponse nonce comment. This // may be empty only if 1) this is a non-persistent-stream xDS such as HTTP, // or 2) the client has not yet accepted an update in this xDS stream (unlike // delta, where it is populated only for new explicit ACKs). ResponseNonce string `protobuf:"bytes,5,opt,name=response_nonce,json=responseNonce,proto3" json:"response_nonce,omitempty"` // This is populated when the previous :ref:`DiscoveryResponse <envoy_api_msg_service.discovery.v4alpha.DiscoveryResponse>` // failed to update configuration. The *message* field in *error_details* provides the Envoy // internal exception related to the failure. It is only intended for consumption during manual // debugging, the string provided is not guaranteed to be stable across Envoy versions. ErrorDetail *status.Status `protobuf:"bytes,6,opt,name=error_detail,json=errorDetail,proto3" json:"error_detail,omitempty"` // contains filtered or unexported fields }
A DiscoveryRequest requests a set of versioned resources of the same type for a given Envoy node on some API. [#next-free-field: 7]
func (*DiscoveryRequest) Descriptor
deprecated
func (*DiscoveryRequest) Descriptor() ([]byte, []int)
Deprecated: Use DiscoveryRequest.ProtoReflect.Descriptor instead.
func (*DiscoveryRequest) GetErrorDetail ¶
func (x *DiscoveryRequest) GetErrorDetail() *status.Status
func (*DiscoveryRequest) GetNode ¶
func (x *DiscoveryRequest) GetNode() *v4alpha.Node
func (*DiscoveryRequest) GetResourceNames ¶
func (x *DiscoveryRequest) GetResourceNames() []string
func (*DiscoveryRequest) GetResponseNonce ¶
func (x *DiscoveryRequest) GetResponseNonce() string
func (*DiscoveryRequest) GetTypeUrl ¶
func (x *DiscoveryRequest) GetTypeUrl() string
func (*DiscoveryRequest) GetVersionInfo ¶
func (x *DiscoveryRequest) GetVersionInfo() string
func (*DiscoveryRequest) ProtoMessage ¶
func (*DiscoveryRequest) ProtoMessage()
func (*DiscoveryRequest) ProtoReflect ¶
func (x *DiscoveryRequest) ProtoReflect() protoreflect.Message
func (*DiscoveryRequest) Reset ¶
func (x *DiscoveryRequest) Reset()
func (*DiscoveryRequest) String ¶
func (x *DiscoveryRequest) String() string
func (*DiscoveryRequest) Validate ¶
func (m *DiscoveryRequest) Validate() error
Validate checks the field values on DiscoveryRequest with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.
type DiscoveryRequestValidationError ¶
type DiscoveryRequestValidationError struct {
// contains filtered or unexported fields
}
DiscoveryRequestValidationError is the validation error returned by DiscoveryRequest.Validate if the designated constraints aren't met.
func (DiscoveryRequestValidationError) Cause ¶
func (e DiscoveryRequestValidationError) Cause() error
Cause function returns cause value.
func (DiscoveryRequestValidationError) Error ¶
func (e DiscoveryRequestValidationError) Error() string
Error satisfies the builtin error interface
func (DiscoveryRequestValidationError) ErrorName ¶
func (e DiscoveryRequestValidationError) ErrorName() string
ErrorName returns error name.
func (DiscoveryRequestValidationError) Field ¶
func (e DiscoveryRequestValidationError) Field() string
Field function returns field value.
func (DiscoveryRequestValidationError) Key ¶
func (e DiscoveryRequestValidationError) Key() bool
Key function returns key value.
func (DiscoveryRequestValidationError) Reason ¶
func (e DiscoveryRequestValidationError) Reason() string
Reason function returns reason value.
type DiscoveryResponse ¶
type DiscoveryResponse struct { // The version of the response data. VersionInfo string `protobuf:"bytes,1,opt,name=version_info,json=versionInfo,proto3" json:"version_info,omitempty"` // The response resources. These resources are typed and depend on the API being called. Resources []*any.Any `protobuf:"bytes,2,rep,name=resources,proto3" json:"resources,omitempty"` // [#not-implemented-hide:] // Canary is used to support two Envoy command line flags: // // * --terminate-on-canary-transition-failure. When set, Envoy is able to // terminate if it detects that configuration is stuck at canary. Consider // this example sequence of updates: // - Management server applies a canary config successfully. // - Management server rolls back to a production config. // - Envoy rejects the new production config. // Since there is no sensible way to continue receiving configuration // updates, Envoy will then terminate and apply production config from a // clean slate. // * --dry-run-canary. When set, a canary response will never be applied, only // validated via a dry run. Canary bool `protobuf:"varint,3,opt,name=canary,proto3" json:"canary,omitempty"` // Type URL for resources. Identifies the xDS API when muxing over ADS. // Must be consistent with the type_url in the 'resources' repeated Any (if non-empty). TypeUrl string `protobuf:"bytes,4,opt,name=type_url,json=typeUrl,proto3" json:"type_url,omitempty"` // For gRPC based subscriptions, the nonce provides a way to explicitly ack a // specific DiscoveryResponse in a following DiscoveryRequest. Additional // messages may have been sent by Envoy to the management server for the // previous version on the stream prior to this DiscoveryResponse, that were // unprocessed at response send time. The nonce allows the management server // to ignore any further DiscoveryRequests for the previous version until a // DiscoveryRequest bearing the nonce. The nonce is optional and is not // required for non-stream based xDS implementations. Nonce string `protobuf:"bytes,5,opt,name=nonce,proto3" json:"nonce,omitempty"` // [#not-implemented-hide:] // The control plane instance that sent the response. ControlPlane *v4alpha.ControlPlane `protobuf:"bytes,6,opt,name=control_plane,json=controlPlane,proto3" json:"control_plane,omitempty"` // contains filtered or unexported fields }
[#next-free-field: 7]
func (*DiscoveryResponse) Descriptor
deprecated
func (*DiscoveryResponse) Descriptor() ([]byte, []int)
Deprecated: Use DiscoveryResponse.ProtoReflect.Descriptor instead.
func (*DiscoveryResponse) GetCanary ¶
func (x *DiscoveryResponse) GetCanary() bool
func (*DiscoveryResponse) GetControlPlane ¶
func (x *DiscoveryResponse) GetControlPlane() *v4alpha.ControlPlane
func (*DiscoveryResponse) GetNonce ¶
func (x *DiscoveryResponse) GetNonce() string
func (*DiscoveryResponse) GetResources ¶
func (x *DiscoveryResponse) GetResources() []*any.Any
func (*DiscoveryResponse) GetTypeUrl ¶
func (x *DiscoveryResponse) GetTypeUrl() string
func (*DiscoveryResponse) GetVersionInfo ¶
func (x *DiscoveryResponse) GetVersionInfo() string
func (*DiscoveryResponse) ProtoMessage ¶
func (*DiscoveryResponse) ProtoMessage()
func (*DiscoveryResponse) ProtoReflect ¶
func (x *DiscoveryResponse) ProtoReflect() protoreflect.Message
func (*DiscoveryResponse) Reset ¶
func (x *DiscoveryResponse) Reset()
func (*DiscoveryResponse) String ¶
func (x *DiscoveryResponse) String() string
func (*DiscoveryResponse) Validate ¶
func (m *DiscoveryResponse) Validate() error
Validate checks the field values on DiscoveryResponse with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.
type DiscoveryResponseValidationError ¶
type DiscoveryResponseValidationError struct {
// contains filtered or unexported fields
}
DiscoveryResponseValidationError is the validation error returned by DiscoveryResponse.Validate if the designated constraints aren't met.
func (DiscoveryResponseValidationError) Cause ¶
func (e DiscoveryResponseValidationError) Cause() error
Cause function returns cause value.
func (DiscoveryResponseValidationError) Error ¶
func (e DiscoveryResponseValidationError) Error() string
Error satisfies the builtin error interface
func (DiscoveryResponseValidationError) ErrorName ¶
func (e DiscoveryResponseValidationError) ErrorName() string
ErrorName returns error name.
func (DiscoveryResponseValidationError) Field ¶
func (e DiscoveryResponseValidationError) Field() string
Field function returns field value.
func (DiscoveryResponseValidationError) Key ¶
func (e DiscoveryResponseValidationError) Key() bool
Key function returns key value.
func (DiscoveryResponseValidationError) Reason ¶
func (e DiscoveryResponseValidationError) Reason() string
Reason function returns reason value.
type Resource ¶
type Resource struct { // Types that are assignable to NameSpecifier: // *Resource_Name // *Resource_UdpaResourceName NameSpecifier isResource_NameSpecifier `protobuf_oneof:"name_specifier"` // The aliases are a list of other names that this resource can go by. Aliases []string `protobuf:"bytes,4,rep,name=aliases,proto3" json:"aliases,omitempty"` // The resource level version. It allows xDS to track the state of individual // resources. Version string `protobuf:"bytes,1,opt,name=version,proto3" json:"version,omitempty"` // The resource being tracked. Resource *any.Any `protobuf:"bytes,2,opt,name=resource,proto3" json:"resource,omitempty"` // contains filtered or unexported fields }
[#next-free-field: 6]
func (*Resource) Descriptor
deprecated
func (*Resource) GetAliases ¶
func (*Resource) GetNameSpecifier ¶ added in v0.9.10
func (m *Resource) GetNameSpecifier() isResource_NameSpecifier
func (*Resource) GetResource ¶
func (*Resource) GetUdpaResourceName ¶ added in v0.9.10
func (x *Resource) GetUdpaResourceName() *v1.ResourceName
func (*Resource) GetVersion ¶
func (*Resource) ProtoMessage ¶
func (*Resource) ProtoMessage()
func (*Resource) ProtoReflect ¶
func (x *Resource) ProtoReflect() protoreflect.Message
type ResourceValidationError ¶
type ResourceValidationError struct {
// contains filtered or unexported fields
}
ResourceValidationError is the validation error returned by Resource.Validate if the designated constraints aren't met.
func (ResourceValidationError) Cause ¶
func (e ResourceValidationError) Cause() error
Cause function returns cause value.
func (ResourceValidationError) Error ¶
func (e ResourceValidationError) Error() string
Error satisfies the builtin error interface
func (ResourceValidationError) ErrorName ¶
func (e ResourceValidationError) ErrorName() string
ErrorName returns error name.
func (ResourceValidationError) Field ¶
func (e ResourceValidationError) Field() string
Field function returns field value.
func (ResourceValidationError) Key ¶
func (e ResourceValidationError) Key() bool
Key function returns key value.
func (ResourceValidationError) Reason ¶
func (e ResourceValidationError) Reason() string
Reason function returns reason value.
type Resource_Name ¶ added in v0.9.10
type Resource_Name struct { // The resource's name, to distinguish it from others of the same type of resource. Name string `protobuf:"bytes,3,opt,name=name,proto3,oneof"` }
type Resource_UdpaResourceName ¶ added in v0.9.10
type Resource_UdpaResourceName struct { // Used instead of *name* when a resource with a *udpa.core.v1.ResourceName* is delivered. UdpaResourceName *v1.ResourceName `protobuf:"bytes,5,opt,name=udpa_resource_name,json=udpaResourceName,proto3,oneof"` }
type UnimplementedAggregatedDiscoveryServiceServer ¶
type UnimplementedAggregatedDiscoveryServiceServer struct { }
UnimplementedAggregatedDiscoveryServiceServer can be embedded to have forward compatible implementations.
func (*UnimplementedAggregatedDiscoveryServiceServer) DeltaAggregatedResources ¶
func (*UnimplementedAggregatedDiscoveryServiceServer) DeltaAggregatedResources(AggregatedDiscoveryService_DeltaAggregatedResourcesServer) error
func (*UnimplementedAggregatedDiscoveryServiceServer) StreamAggregatedResources ¶
func (*UnimplementedAggregatedDiscoveryServiceServer) StreamAggregatedResources(AggregatedDiscoveryService_StreamAggregatedResourcesServer) error