v1alpha1

package
v0.10.7 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Dec 8, 2020 License: Apache-2.0 Imports: 10 Imported by: 0

Documentation

Index

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
	//	*GeneratedObject_ConfigMap_
	//	*GeneratedObject_XdsConfig
	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) GetConfigMap added in v0.10.4 

func (m *GeneratedObject) GetConfigMap() *GeneratedObject_ConfigMap

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) GetXdsConfig added in v0.10.4 

func (m *GeneratedObject) GetXdsConfig() *v1alpha1.XdsConfigSpec

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_ConfigMap added in v0.10.4 

type GeneratedObject_ConfigMap struct {
	Data                 map[string]string `` /* 149-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

func (*GeneratedObject_ConfigMap) Descriptor added in v0.10.4 

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

func (*GeneratedObject_ConfigMap) GetData added in v0.10.4 

func (m *GeneratedObject_ConfigMap) GetData() map[string]string

func (*GeneratedObject_ConfigMap) ProtoMessage added in v0.10.4 

func (*GeneratedObject_ConfigMap) ProtoMessage()

func (*GeneratedObject_ConfigMap) Reset added in v0.10.4 

func (m *GeneratedObject_ConfigMap) Reset()

func (*GeneratedObject_ConfigMap) String added in v0.10.4 

func (m *GeneratedObject_ConfigMap) String() string

func (*GeneratedObject_ConfigMap) XXX_DiscardUnknown added in v0.10.4 

func (m *GeneratedObject_ConfigMap) XXX_DiscardUnknown()

func (*GeneratedObject_ConfigMap) XXX_Marshal added in v0.10.4 

func (m *GeneratedObject_ConfigMap) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GeneratedObject_ConfigMap) XXX_Merge added in v0.10.4 

func (m *GeneratedObject_ConfigMap) XXX_Merge(src proto.Message)

func (*GeneratedObject_ConfigMap) XXX_Size added in v0.10.4 

func (m *GeneratedObject_ConfigMap) XXX_Size() int

func (*GeneratedObject_ConfigMap) XXX_Unmarshal added in v0.10.4 

func (m *GeneratedObject_ConfigMap) XXX_Unmarshal(b []byte) error

type GeneratedObject_ConfigMap_ added in v0.10.4 

type GeneratedObject_ConfigMap_ struct {
	ConfigMap *GeneratedObject_ConfigMap `protobuf:"bytes,6,opt,name=config_map,json=configMap,proto3,oneof" json:"config_map,omitempty"`
}

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 GeneratedObject_XdsConfig added in v0.10.4 

type GeneratedObject_XdsConfig struct {
	XdsConfig *v1alpha1.XdsConfigSpec `protobuf:"bytes,7,opt,name=xds_config,json=xdsConfig,proto3,oneof" json:"xds_config,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

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.