Documentation ¶
Index ¶
- func RegisterNetworkingExtensionsServer(s *grpc.Server, srv NetworkingExtensionsServer)
- type DiscoverySnapshot
- func (*DiscoverySnapshot) Descriptor() ([]byte, []int)
- func (m *DiscoverySnapshot) GetMeshes() []*MeshObject
- func (m *DiscoverySnapshot) GetTrafficTargets() []*TrafficTargetObject
- func (m *DiscoverySnapshot) GetWorkloads() []*WorkloadObject
- func (*DiscoverySnapshot) ProtoMessage()
- func (m *DiscoverySnapshot) Reset()
- func (m *DiscoverySnapshot) String() string
- func (m *DiscoverySnapshot) XXX_DiscardUnknown()
- func (m *DiscoverySnapshot) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *DiscoverySnapshot) XXX_Merge(src proto.Message)
- func (m *DiscoverySnapshot) XXX_Size() int
- func (m *DiscoverySnapshot) XXX_Unmarshal(b []byte) error
- type ExtensionPatchRequest
- func (*ExtensionPatchRequest) Descriptor() ([]byte, []int)
- func (m *ExtensionPatchRequest) GetInputs() *DiscoverySnapshot
- func (m *ExtensionPatchRequest) GetOutputs() []*GeneratedObject
- func (*ExtensionPatchRequest) ProtoMessage()
- func (m *ExtensionPatchRequest) Reset()
- func (m *ExtensionPatchRequest) String() string
- func (m *ExtensionPatchRequest) XXX_DiscardUnknown()
- func (m *ExtensionPatchRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ExtensionPatchRequest) XXX_Merge(src proto.Message)
- func (m *ExtensionPatchRequest) XXX_Size() int
- func (m *ExtensionPatchRequest) XXX_Unmarshal(b []byte) error
- type ExtensionPatchResponse
- func (*ExtensionPatchResponse) Descriptor() ([]byte, []int)
- func (m *ExtensionPatchResponse) GetPatchedOutputs() []*GeneratedObject
- func (*ExtensionPatchResponse) ProtoMessage()
- func (m *ExtensionPatchResponse) Reset()
- func (m *ExtensionPatchResponse) String() string
- func (m *ExtensionPatchResponse) XXX_DiscardUnknown()
- func (m *ExtensionPatchResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ExtensionPatchResponse) XXX_Merge(src proto.Message)
- func (m *ExtensionPatchResponse) XXX_Size() int
- func (m *ExtensionPatchResponse) XXX_Unmarshal(b []byte) error
- type GeneratedObject
- func (*GeneratedObject) Descriptor() ([]byte, []int)
- func (m *GeneratedObject) GetDestinationRule() *v1alpha3.DestinationRule
- func (m *GeneratedObject) GetEnvoyFilter() *v1alpha3.EnvoyFilter
- func (m *GeneratedObject) GetMetadata() *ObjectMeta
- func (m *GeneratedObject) GetServiceEntry() *v1alpha3.ServiceEntry
- func (m *GeneratedObject) GetType() isGeneratedObject_Type
- func (m *GeneratedObject) GetVirtualService() *v1alpha3.VirtualService
- func (*GeneratedObject) ProtoMessage()
- func (m *GeneratedObject) Reset()
- func (m *GeneratedObject) String() string
- func (m *GeneratedObject) XXX_DiscardUnknown()
- func (m *GeneratedObject) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *GeneratedObject) XXX_Merge(src proto.Message)
- func (*GeneratedObject) XXX_OneofWrappers() []interface{}
- func (m *GeneratedObject) XXX_Size() int
- func (m *GeneratedObject) XXX_Unmarshal(b []byte) error
- type GeneratedObject_DestinationRule
- type GeneratedObject_EnvoyFilter
- type GeneratedObject_ServiceEntry
- type GeneratedObject_VirtualService
- type MeshObject
- func (*MeshObject) Descriptor() ([]byte, []int)
- func (m *MeshObject) GetMetadata() *ObjectMeta
- func (m *MeshObject) GetSpec() *v1alpha2.MeshSpec
- func (m *MeshObject) GetStatus() *v1alpha2.MeshStatus
- func (*MeshObject) ProtoMessage()
- func (m *MeshObject) Reset()
- func (m *MeshObject) String() string
- func (m *MeshObject) XXX_DiscardUnknown()
- func (m *MeshObject) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *MeshObject) XXX_Merge(src proto.Message)
- func (m *MeshObject) XXX_Size() int
- func (m *MeshObject) XXX_Unmarshal(b []byte) error
- type NetworkingExtensionsClient
- type NetworkingExtensionsServer
- type NetworkingExtensions_WatchPushNotificationsClient
- type NetworkingExtensions_WatchPushNotificationsServer
- type ObjectMeta
- func (*ObjectMeta) Descriptor() ([]byte, []int)
- func (m *ObjectMeta) GetAnnotations() map[string]string
- func (m *ObjectMeta) GetClusterName() string
- func (m *ObjectMeta) GetLabels() map[string]string
- func (m *ObjectMeta) GetName() string
- func (m *ObjectMeta) GetNamespace() string
- func (*ObjectMeta) ProtoMessage()
- func (m *ObjectMeta) Reset()
- func (m *ObjectMeta) String() string
- func (m *ObjectMeta) XXX_DiscardUnknown()
- func (m *ObjectMeta) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ObjectMeta) XXX_Merge(src proto.Message)
- func (m *ObjectMeta) XXX_Size() int
- func (m *ObjectMeta) XXX_Unmarshal(b []byte) error
- type PushNotification
- func (*PushNotification) Descriptor() ([]byte, []int)
- func (*PushNotification) ProtoMessage()
- func (m *PushNotification) Reset()
- func (m *PushNotification) String() string
- func (m *PushNotification) XXX_DiscardUnknown()
- func (m *PushNotification) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *PushNotification) XXX_Merge(src proto.Message)
- func (m *PushNotification) XXX_Size() int
- func (m *PushNotification) XXX_Unmarshal(b []byte) error
- type TrafficTargetObject
- func (*TrafficTargetObject) Descriptor() ([]byte, []int)
- func (m *TrafficTargetObject) GetMetadata() *ObjectMeta
- func (m *TrafficTargetObject) GetSpec() *v1alpha2.TrafficTargetSpec
- func (m *TrafficTargetObject) GetStatus() *v1alpha2.TrafficTargetStatus
- func (*TrafficTargetObject) ProtoMessage()
- func (m *TrafficTargetObject) Reset()
- func (m *TrafficTargetObject) String() string
- func (m *TrafficTargetObject) XXX_DiscardUnknown()
- func (m *TrafficTargetObject) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *TrafficTargetObject) XXX_Merge(src proto.Message)
- func (m *TrafficTargetObject) XXX_Size() int
- func (m *TrafficTargetObject) XXX_Unmarshal(b []byte) error
- type UnimplementedNetworkingExtensionsServer
- type WatchPushNotificationsRequest
- func (*WatchPushNotificationsRequest) Descriptor() ([]byte, []int)
- func (*WatchPushNotificationsRequest) ProtoMessage()
- func (m *WatchPushNotificationsRequest) Reset()
- func (m *WatchPushNotificationsRequest) String() string
- func (m *WatchPushNotificationsRequest) XXX_DiscardUnknown()
- func (m *WatchPushNotificationsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *WatchPushNotificationsRequest) XXX_Merge(src proto.Message)
- func (m *WatchPushNotificationsRequest) XXX_Size() int
- func (m *WatchPushNotificationsRequest) XXX_Unmarshal(b []byte) error
- type WorkloadObject
- func (*WorkloadObject) Descriptor() ([]byte, []int)
- func (m *WorkloadObject) GetMetadata() *ObjectMeta
- func (m *WorkloadObject) GetSpec() *v1alpha2.WorkloadSpec
- func (m *WorkloadObject) GetStatus() *v1alpha2.WorkloadStatus
- func (*WorkloadObject) ProtoMessage()
- func (m *WorkloadObject) Reset()
- func (m *WorkloadObject) String() string
- func (m *WorkloadObject) XXX_DiscardUnknown()
- func (m *WorkloadObject) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *WorkloadObject) XXX_Merge(src proto.Message)
- func (m *WorkloadObject) XXX_Size() int
- func (m *WorkloadObject) XXX_Unmarshal(b []byte) error
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func RegisterNetworkingExtensionsServer ¶
func RegisterNetworkingExtensionsServer(s *grpc.Server, srv NetworkingExtensionsServer)
Types ¶
type DiscoverySnapshot ¶
type DiscoverySnapshot struct { // all meshes in the discovery snapshot Meshes []*MeshObject `protobuf:"bytes,1,rep,name=meshes,proto3" json:"meshes,omitempty"` // all traffic targets in the discovery snapshot TrafficTargets []*TrafficTargetObject `protobuf:"bytes,2,rep,name=traffic_targets,json=trafficTargets,proto3" json:"traffic_targets,omitempty"` // all workloads in the discovery snapshot Workloads []*WorkloadObject `protobuf:"bytes,3,rep,name=workloads,proto3" json:"workloads,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
a Protobuf representation of the set of Discovery objects used to produce the Networking outputs.
func (*DiscoverySnapshot) Descriptor ¶
func (*DiscoverySnapshot) Descriptor() ([]byte, []int)
func (*DiscoverySnapshot) GetMeshes ¶
func (m *DiscoverySnapshot) GetMeshes() []*MeshObject
func (*DiscoverySnapshot) GetTrafficTargets ¶
func (m *DiscoverySnapshot) GetTrafficTargets() []*TrafficTargetObject
func (*DiscoverySnapshot) GetWorkloads ¶
func (m *DiscoverySnapshot) GetWorkloads() []*WorkloadObject
func (*DiscoverySnapshot) ProtoMessage ¶
func (*DiscoverySnapshot) ProtoMessage()
func (*DiscoverySnapshot) Reset ¶
func (m *DiscoverySnapshot) Reset()
func (*DiscoverySnapshot) String ¶
func (m *DiscoverySnapshot) String() string
func (*DiscoverySnapshot) XXX_DiscardUnknown ¶
func (m *DiscoverySnapshot) XXX_DiscardUnknown()
func (*DiscoverySnapshot) XXX_Marshal ¶
func (m *DiscoverySnapshot) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*DiscoverySnapshot) XXX_Merge ¶
func (m *DiscoverySnapshot) XXX_Merge(src proto.Message)
func (*DiscoverySnapshot) XXX_Size ¶
func (m *DiscoverySnapshot) XXX_Size() int
func (*DiscoverySnapshot) XXX_Unmarshal ¶
func (m *DiscoverySnapshot) XXX_Unmarshal(b []byte) error
type ExtensionPatchRequest ¶
type ExtensionPatchRequest struct { // the set of discovery objects provided as inputs for the Gloo Mesh translation Inputs *DiscoverySnapshot `protobuf:"bytes,1,opt,name=inputs,proto3" json:"inputs,omitempty"` // the base set of output objects translated by Gloo Mesh. // these may have been operated upon by a previous Extension server if multiple servers // have been configured. Outputs []*GeneratedObject `protobuf:"bytes,2,rep,name=outputs,proto3" json:"outputs,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
the parameters provided to the Extensions server when requesting patches
func (*ExtensionPatchRequest) Descriptor ¶
func (*ExtensionPatchRequest) Descriptor() ([]byte, []int)
func (*ExtensionPatchRequest) GetInputs ¶
func (m *ExtensionPatchRequest) GetInputs() *DiscoverySnapshot
func (*ExtensionPatchRequest) GetOutputs ¶
func (m *ExtensionPatchRequest) GetOutputs() []*GeneratedObject
func (*ExtensionPatchRequest) ProtoMessage ¶
func (*ExtensionPatchRequest) ProtoMessage()
func (*ExtensionPatchRequest) Reset ¶
func (m *ExtensionPatchRequest) Reset()
func (*ExtensionPatchRequest) String ¶
func (m *ExtensionPatchRequest) String() string
func (*ExtensionPatchRequest) XXX_DiscardUnknown ¶
func (m *ExtensionPatchRequest) XXX_DiscardUnknown()
func (*ExtensionPatchRequest) XXX_Marshal ¶
func (m *ExtensionPatchRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ExtensionPatchRequest) XXX_Merge ¶
func (m *ExtensionPatchRequest) XXX_Merge(src proto.Message)
func (*ExtensionPatchRequest) XXX_Size ¶
func (m *ExtensionPatchRequest) XXX_Size() int
func (*ExtensionPatchRequest) XXX_Unmarshal ¶
func (m *ExtensionPatchRequest) XXX_Unmarshal(b []byte) error
type ExtensionPatchResponse ¶
type ExtensionPatchResponse struct { // the set of modified/added output objects desired by the Extension server. PatchedOutputs []*GeneratedObject `protobuf:"bytes,1,rep,name=patched_outputs,json=patchedOutputs,proto3" json:"patched_outputs,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
the set of patches the server wishes to apply to the Gloo Mesh Networking outputs. Any objects provided here will be inserted into the final Gloo Mesh snapshot. If an object already exists in the snapshot, it will be overridden by the version provided here. If multiple extensions servers are configured, this response may be operated upon by Extension patches provided by subsequent servers.
func (*ExtensionPatchResponse) Descriptor ¶
func (*ExtensionPatchResponse) Descriptor() ([]byte, []int)
func (*ExtensionPatchResponse) GetPatchedOutputs ¶
func (m *ExtensionPatchResponse) GetPatchedOutputs() []*GeneratedObject
func (*ExtensionPatchResponse) ProtoMessage ¶
func (*ExtensionPatchResponse) ProtoMessage()
func (*ExtensionPatchResponse) Reset ¶
func (m *ExtensionPatchResponse) Reset()
func (*ExtensionPatchResponse) String ¶
func (m *ExtensionPatchResponse) String() string
func (*ExtensionPatchResponse) XXX_DiscardUnknown ¶
func (m *ExtensionPatchResponse) XXX_DiscardUnknown()
func (*ExtensionPatchResponse) XXX_Marshal ¶
func (m *ExtensionPatchResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ExtensionPatchResponse) XXX_Merge ¶
func (m *ExtensionPatchResponse) XXX_Merge(src proto.Message)
func (*ExtensionPatchResponse) XXX_Size ¶
func (m *ExtensionPatchResponse) XXX_Size() int
func (*ExtensionPatchResponse) XXX_Unmarshal ¶
func (m *ExtensionPatchResponse) XXX_Unmarshal(b []byte) error
type GeneratedObject ¶
type GeneratedObject struct { // metadata of the object Metadata *ObjectMeta `protobuf:"bytes,1,opt,name=metadata,proto3" json:"metadata,omitempty"` // type of the object. // // Types that are valid to be assigned to Type: // *GeneratedObject_DestinationRule // *GeneratedObject_EnvoyFilter // *GeneratedObject_ServiceEntry // *GeneratedObject_VirtualService Type isGeneratedObject_Type `protobuf_oneof:"type"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
a generated object can be of any output type supported by Gloo Mesh. the content of the type field should be used to determine the type of the output object. TODO(ilackarms): consider parameterizing Gloo Mesh to allow excluding GeneratedObjects from patch requests in the case where an implementer only performs additions (no updates required).
func (*GeneratedObject) Descriptor ¶
func (*GeneratedObject) Descriptor() ([]byte, []int)
func (*GeneratedObject) GetDestinationRule ¶
func (m *GeneratedObject) GetDestinationRule() *v1alpha3.DestinationRule
func (*GeneratedObject) GetEnvoyFilter ¶
func (m *GeneratedObject) GetEnvoyFilter() *v1alpha3.EnvoyFilter
func (*GeneratedObject) GetMetadata ¶
func (m *GeneratedObject) GetMetadata() *ObjectMeta
func (*GeneratedObject) GetServiceEntry ¶
func (m *GeneratedObject) GetServiceEntry() *v1alpha3.ServiceEntry
func (*GeneratedObject) GetType ¶
func (m *GeneratedObject) GetType() isGeneratedObject_Type
func (*GeneratedObject) GetVirtualService ¶
func (m *GeneratedObject) GetVirtualService() *v1alpha3.VirtualService
func (*GeneratedObject) ProtoMessage ¶
func (*GeneratedObject) ProtoMessage()
func (*GeneratedObject) Reset ¶
func (m *GeneratedObject) Reset()
func (*GeneratedObject) String ¶
func (m *GeneratedObject) String() string
func (*GeneratedObject) XXX_DiscardUnknown ¶
func (m *GeneratedObject) XXX_DiscardUnknown()
func (*GeneratedObject) XXX_Marshal ¶
func (m *GeneratedObject) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*GeneratedObject) XXX_Merge ¶
func (m *GeneratedObject) XXX_Merge(src proto.Message)
func (*GeneratedObject) XXX_OneofWrappers ¶
func (*GeneratedObject) XXX_OneofWrappers() []interface{}
XXX_OneofWrappers is for the internal use of the proto package.
func (*GeneratedObject) XXX_Size ¶
func (m *GeneratedObject) XXX_Size() int
func (*GeneratedObject) XXX_Unmarshal ¶
func (m *GeneratedObject) XXX_Unmarshal(b []byte) error
type GeneratedObject_DestinationRule ¶
type GeneratedObject_DestinationRule struct {
DestinationRule *v1alpha3.DestinationRule `protobuf:"bytes,2,opt,name=destination_rule,json=destinationRule,proto3,oneof" json:"destination_rule,omitempty"`
}
type GeneratedObject_EnvoyFilter ¶
type GeneratedObject_EnvoyFilter struct {
EnvoyFilter *v1alpha3.EnvoyFilter `protobuf:"bytes,3,opt,name=envoy_filter,json=envoyFilter,proto3,oneof" json:"envoy_filter,omitempty"`
}
type GeneratedObject_ServiceEntry ¶
type GeneratedObject_ServiceEntry struct {
ServiceEntry *v1alpha3.ServiceEntry `protobuf:"bytes,4,opt,name=service_entry,json=serviceEntry,proto3,oneof" json:"service_entry,omitempty"`
}
type GeneratedObject_VirtualService ¶
type GeneratedObject_VirtualService struct {
VirtualService *v1alpha3.VirtualService `protobuf:"bytes,5,opt,name=virtual_service,json=virtualService,proto3,oneof" json:"virtual_service,omitempty"`
}
type MeshObject ¶
type MeshObject struct { // metadata of the object Metadata *ObjectMeta `protobuf:"bytes,1,opt,name=metadata,proto3" json:"metadata,omitempty"` // the spec of the object Spec *v1alpha2.MeshSpec `protobuf:"bytes,2,opt,name=spec,proto3" json:"spec,omitempty"` // the status of the object Status *v1alpha2.MeshStatus `protobuf:"bytes,3,opt,name=status,proto3" json:"status,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
a proto-serializable representation of a Mesh object
func (*MeshObject) Descriptor ¶
func (*MeshObject) Descriptor() ([]byte, []int)
func (*MeshObject) GetMetadata ¶
func (m *MeshObject) GetMetadata() *ObjectMeta
func (*MeshObject) GetSpec ¶
func (m *MeshObject) GetSpec() *v1alpha2.MeshSpec
func (*MeshObject) GetStatus ¶
func (m *MeshObject) GetStatus() *v1alpha2.MeshStatus
func (*MeshObject) ProtoMessage ¶
func (*MeshObject) ProtoMessage()
func (*MeshObject) Reset ¶
func (m *MeshObject) Reset()
func (*MeshObject) String ¶
func (m *MeshObject) String() string
func (*MeshObject) XXX_DiscardUnknown ¶
func (m *MeshObject) XXX_DiscardUnknown()
func (*MeshObject) XXX_Marshal ¶
func (m *MeshObject) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*MeshObject) XXX_Merge ¶
func (m *MeshObject) XXX_Merge(src proto.Message)
func (*MeshObject) XXX_Size ¶
func (m *MeshObject) XXX_Size() int
func (*MeshObject) XXX_Unmarshal ¶
func (m *MeshObject) XXX_Unmarshal(b []byte) error
type NetworkingExtensionsClient ¶
type NetworkingExtensionsClient interface { // GetExtensionPatches fetches a set of patches to the output configuration from the Extensions server. // The current discovery snapshot and translated outputs are provided in the ExtensionPatchRequest GetExtensionPatches(ctx context.Context, in *ExtensionPatchRequest, opts ...grpc.CallOption) (*ExtensionPatchResponse, error) // WatchPushNotifications initiates a streaming connection which allows the NetworkingExtensions server // to push notifications to Gloo Mesh telling it to resync its configuration. // This allows a NetworkingExtensions server to trigger Gloo Mesh to resync its state for // events triggered by objects not watched by Gloo Mesh. WatchPushNotifications(ctx context.Context, in *WatchPushNotificationsRequest, opts ...grpc.CallOption) (NetworkingExtensions_WatchPushNotificationsClient, error) }
NetworkingExtensionsClient is the client API for NetworkingExtensions service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.
func NewNetworkingExtensionsClient ¶
func NewNetworkingExtensionsClient(cc *grpc.ClientConn) NetworkingExtensionsClient
type NetworkingExtensionsServer ¶
type NetworkingExtensionsServer interface { // GetExtensionPatches fetches a set of patches to the output configuration from the Extensions server. // The current discovery snapshot and translated outputs are provided in the ExtensionPatchRequest GetExtensionPatches(context.Context, *ExtensionPatchRequest) (*ExtensionPatchResponse, error) // WatchPushNotifications initiates a streaming connection which allows the NetworkingExtensions server // to push notifications to Gloo Mesh telling it to resync its configuration. // This allows a NetworkingExtensions server to trigger Gloo Mesh to resync its state for // events triggered by objects not watched by Gloo Mesh. WatchPushNotifications(*WatchPushNotificationsRequest, NetworkingExtensions_WatchPushNotificationsServer) error }
NetworkingExtensionsServer is the server API for NetworkingExtensions service.
type NetworkingExtensions_WatchPushNotificationsClient ¶
type NetworkingExtensions_WatchPushNotificationsClient interface { Recv() (*PushNotification, error) grpc.ClientStream }
type NetworkingExtensions_WatchPushNotificationsServer ¶
type NetworkingExtensions_WatchPushNotificationsServer interface { Send(*PushNotification) error grpc.ServerStream }
type ObjectMeta ¶
type ObjectMeta struct { // the kubernetes name of the object Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` // the kubernetes namespace of the object Namespace string `protobuf:"bytes,2,opt,name=namespace,proto3" json:"namespace,omitempty"` // the kubernetes clusterName of the object (used internally by Gloo Mesh) ClusterName string `protobuf:"bytes,3,opt,name=cluster_name,json=clusterName,proto3" json:"cluster_name,omitempty"` // the kubernetes labels on the object Labels map[string]string `` /* 153-byte string literal not displayed */ // the kubernetes annotations on the object Annotations map[string]string `` /* 163-byte string literal not displayed */ XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
ObjectMeta is a simplified clone of the kubernetes ObjectMeta used to represent object metadata for K8s objects passed as messages in the NetworkingExtensions API.
func (*ObjectMeta) Descriptor ¶
func (*ObjectMeta) Descriptor() ([]byte, []int)
func (*ObjectMeta) GetAnnotations ¶
func (m *ObjectMeta) GetAnnotations() map[string]string
func (*ObjectMeta) GetClusterName ¶
func (m *ObjectMeta) GetClusterName() string
func (*ObjectMeta) GetLabels ¶
func (m *ObjectMeta) GetLabels() map[string]string
func (*ObjectMeta) GetName ¶
func (m *ObjectMeta) GetName() string
func (*ObjectMeta) GetNamespace ¶
func (m *ObjectMeta) GetNamespace() string
func (*ObjectMeta) ProtoMessage ¶
func (*ObjectMeta) ProtoMessage()
func (*ObjectMeta) Reset ¶
func (m *ObjectMeta) Reset()
func (*ObjectMeta) String ¶
func (m *ObjectMeta) String() string
func (*ObjectMeta) XXX_DiscardUnknown ¶
func (m *ObjectMeta) XXX_DiscardUnknown()
func (*ObjectMeta) XXX_Marshal ¶
func (m *ObjectMeta) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ObjectMeta) XXX_Merge ¶
func (m *ObjectMeta) XXX_Merge(src proto.Message)
func (*ObjectMeta) XXX_Size ¶
func (m *ObjectMeta) XXX_Size() int
func (*ObjectMeta) XXX_Unmarshal ¶
func (m *ObjectMeta) XXX_Unmarshal(b []byte) error
type PushNotification ¶
type PushNotification struct { XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
triggers a resync of Gloo Mesh objects
func (*PushNotification) Descriptor ¶
func (*PushNotification) Descriptor() ([]byte, []int)
func (*PushNotification) ProtoMessage ¶
func (*PushNotification) ProtoMessage()
func (*PushNotification) Reset ¶
func (m *PushNotification) Reset()
func (*PushNotification) String ¶
func (m *PushNotification) String() string
func (*PushNotification) XXX_DiscardUnknown ¶
func (m *PushNotification) XXX_DiscardUnknown()
func (*PushNotification) XXX_Marshal ¶
func (m *PushNotification) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*PushNotification) XXX_Merge ¶
func (m *PushNotification) XXX_Merge(src proto.Message)
func (*PushNotification) XXX_Size ¶
func (m *PushNotification) XXX_Size() int
func (*PushNotification) XXX_Unmarshal ¶
func (m *PushNotification) XXX_Unmarshal(b []byte) error
type TrafficTargetObject ¶
type TrafficTargetObject struct { // metadata of the object Metadata *ObjectMeta `protobuf:"bytes,1,opt,name=metadata,proto3" json:"metadata,omitempty"` // the spec of the object Spec *v1alpha2.TrafficTargetSpec `protobuf:"bytes,2,opt,name=spec,proto3" json:"spec,omitempty"` // the status of the object Status *v1alpha2.TrafficTargetStatus `protobuf:"bytes,3,opt,name=status,proto3" json:"status,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
a proto-serializable representation of a TrafficTarget object
func (*TrafficTargetObject) Descriptor ¶
func (*TrafficTargetObject) Descriptor() ([]byte, []int)
func (*TrafficTargetObject) GetMetadata ¶
func (m *TrafficTargetObject) GetMetadata() *ObjectMeta
func (*TrafficTargetObject) GetSpec ¶
func (m *TrafficTargetObject) GetSpec() *v1alpha2.TrafficTargetSpec
func (*TrafficTargetObject) GetStatus ¶
func (m *TrafficTargetObject) GetStatus() *v1alpha2.TrafficTargetStatus
func (*TrafficTargetObject) ProtoMessage ¶
func (*TrafficTargetObject) ProtoMessage()
func (*TrafficTargetObject) Reset ¶
func (m *TrafficTargetObject) Reset()
func (*TrafficTargetObject) String ¶
func (m *TrafficTargetObject) String() string
func (*TrafficTargetObject) XXX_DiscardUnknown ¶
func (m *TrafficTargetObject) XXX_DiscardUnknown()
func (*TrafficTargetObject) XXX_Marshal ¶
func (m *TrafficTargetObject) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*TrafficTargetObject) XXX_Merge ¶
func (m *TrafficTargetObject) XXX_Merge(src proto.Message)
func (*TrafficTargetObject) XXX_Size ¶
func (m *TrafficTargetObject) XXX_Size() int
func (*TrafficTargetObject) XXX_Unmarshal ¶
func (m *TrafficTargetObject) XXX_Unmarshal(b []byte) error
type UnimplementedNetworkingExtensionsServer ¶
type UnimplementedNetworkingExtensionsServer struct { }
UnimplementedNetworkingExtensionsServer can be embedded to have forward compatible implementations.
func (*UnimplementedNetworkingExtensionsServer) GetExtensionPatches ¶
func (*UnimplementedNetworkingExtensionsServer) GetExtensionPatches(ctx context.Context, req *ExtensionPatchRequest) (*ExtensionPatchResponse, error)
func (*UnimplementedNetworkingExtensionsServer) WatchPushNotifications ¶
func (*UnimplementedNetworkingExtensionsServer) WatchPushNotifications(req *WatchPushNotificationsRequest, srv NetworkingExtensions_WatchPushNotificationsServer) error
type WatchPushNotificationsRequest ¶
type WatchPushNotificationsRequest struct { XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
request to initiate push notifications
func (*WatchPushNotificationsRequest) Descriptor ¶
func (*WatchPushNotificationsRequest) Descriptor() ([]byte, []int)
func (*WatchPushNotificationsRequest) ProtoMessage ¶
func (*WatchPushNotificationsRequest) ProtoMessage()
func (*WatchPushNotificationsRequest) Reset ¶
func (m *WatchPushNotificationsRequest) Reset()
func (*WatchPushNotificationsRequest) String ¶
func (m *WatchPushNotificationsRequest) String() string
func (*WatchPushNotificationsRequest) XXX_DiscardUnknown ¶
func (m *WatchPushNotificationsRequest) XXX_DiscardUnknown()
func (*WatchPushNotificationsRequest) XXX_Marshal ¶
func (m *WatchPushNotificationsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*WatchPushNotificationsRequest) XXX_Merge ¶
func (m *WatchPushNotificationsRequest) XXX_Merge(src proto.Message)
func (*WatchPushNotificationsRequest) XXX_Size ¶
func (m *WatchPushNotificationsRequest) XXX_Size() int
func (*WatchPushNotificationsRequest) XXX_Unmarshal ¶
func (m *WatchPushNotificationsRequest) XXX_Unmarshal(b []byte) error
type WorkloadObject ¶
type WorkloadObject struct { // metadata of the object Metadata *ObjectMeta `protobuf:"bytes,1,opt,name=metadata,proto3" json:"metadata,omitempty"` // the spec of the object Spec *v1alpha2.WorkloadSpec `protobuf:"bytes,2,opt,name=spec,proto3" json:"spec,omitempty"` // the status of the object Status *v1alpha2.WorkloadStatus `protobuf:"bytes,3,opt,name=status,proto3" json:"status,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
a proto-serializable representation of a Workload object
func (*WorkloadObject) Descriptor ¶
func (*WorkloadObject) Descriptor() ([]byte, []int)
func (*WorkloadObject) GetMetadata ¶
func (m *WorkloadObject) GetMetadata() *ObjectMeta
func (*WorkloadObject) GetSpec ¶
func (m *WorkloadObject) GetSpec() *v1alpha2.WorkloadSpec
func (*WorkloadObject) GetStatus ¶
func (m *WorkloadObject) GetStatus() *v1alpha2.WorkloadStatus
func (*WorkloadObject) ProtoMessage ¶
func (*WorkloadObject) ProtoMessage()
func (*WorkloadObject) Reset ¶
func (m *WorkloadObject) Reset()
func (*WorkloadObject) String ¶
func (m *WorkloadObject) String() string
func (*WorkloadObject) XXX_DiscardUnknown ¶
func (m *WorkloadObject) XXX_DiscardUnknown()
func (*WorkloadObject) XXX_Marshal ¶
func (m *WorkloadObject) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*WorkloadObject) XXX_Merge ¶
func (m *WorkloadObject) XXX_Merge(src proto.Message)
func (*WorkloadObject) XXX_Size ¶
func (m *WorkloadObject) XXX_Size() int
func (*WorkloadObject) XXX_Unmarshal ¶
func (m *WorkloadObject) XXX_Unmarshal(b []byte) error