Documentation ¶
Overview ¶
Package v1alpha1 contains API Schema definitions for the networking.enterprise.mesh.gloo.solo.io v1alpha1 API group +k8s:deepcopy-gen=package,register +groupName=networking.enterprise.mesh.gloo.solo.io
NOTE: Boilerplate only. Ignore this file. Used to register the Go types with the Kubernetes internal scheme
Definitions for the Kubernetes types ¶
Definitions for the Kubernetes types
Index ¶
- Variables
- func AddToScheme(s *runtime.Scheme) error
- func NewWasmDeploymentClient(client client.Client) *wasmDeploymentClient
- func Resource(resource string) schema.GroupResource
- type Clientset
- type ImagePullOptions
- func (*ImagePullOptions) Descriptor() ([]byte, []int)deprecated
- func (x *ImagePullOptions) GetInsecureSkipVerify() bool
- func (x *ImagePullOptions) GetPlainHttp() bool
- func (x *ImagePullOptions) GetPullSecret() string
- func (*ImagePullOptions) ProtoMessage()
- func (x *ImagePullOptions) ProtoReflect() protoreflect.Message
- func (x *ImagePullOptions) Reset()
- func (x *ImagePullOptions) String() string
- type MulticlusterClientset
- type MulticlusterWasmDeploymentClient
- type UriSource
- type WasmDeployment
- type WasmDeploymentClient
- type WasmDeploymentList
- type WasmDeploymentReader
- type WasmDeploymentSlice
- type WasmDeploymentSpec
- func (in *WasmDeploymentSpec) DeepCopyInto(out *WasmDeploymentSpec)
- func (*WasmDeploymentSpec) Descriptor() ([]byte, []int)deprecated
- func (x *WasmDeploymentSpec) GetFilters() []*WasmFilterSpec
- func (x *WasmDeploymentSpec) GetWeight() uint32
- func (x *WasmDeploymentSpec) GetWorkloadSelector() []*v1alpha2.WorkloadSelector
- func (this *WasmDeploymentSpec) MarshalJSON() ([]byte, error)
- func (*WasmDeploymentSpec) ProtoMessage()
- func (x *WasmDeploymentSpec) ProtoReflect() protoreflect.Message
- func (x *WasmDeploymentSpec) Reset()
- func (x *WasmDeploymentSpec) String() string
- func (this *WasmDeploymentSpec) UnmarshalJSON(b []byte) error
- type WasmDeploymentStatus
- func (in *WasmDeploymentStatus) DeepCopyInto(out *WasmDeploymentStatus)
- func (*WasmDeploymentStatus) Descriptor() ([]byte, []int)deprecated
- func (x *WasmDeploymentStatus) GetError() string
- func (x *WasmDeploymentStatus) GetObservedGeneration() int64
- func (x *WasmDeploymentStatus) GetWorkloadStates() map[string]WasmDeploymentStatus_WorkloadState
- func (this *WasmDeploymentStatus) MarshalJSON() ([]byte, error)
- func (*WasmDeploymentStatus) ProtoMessage()
- func (x *WasmDeploymentStatus) ProtoReflect() protoreflect.Message
- func (x *WasmDeploymentStatus) Reset()
- func (x *WasmDeploymentStatus) String() string
- func (this *WasmDeploymentStatus) UnmarshalJSON(b []byte) error
- type WasmDeploymentStatusWriter
- type WasmDeploymentStatus_WorkloadState
- func (WasmDeploymentStatus_WorkloadState) Descriptor() protoreflect.EnumDescriptor
- func (x WasmDeploymentStatus_WorkloadState) Enum() *WasmDeploymentStatus_WorkloadState
- func (WasmDeploymentStatus_WorkloadState) EnumDescriptor() ([]byte, []int)deprecated
- func (x WasmDeploymentStatus_WorkloadState) Number() protoreflect.EnumNumber
- func (x WasmDeploymentStatus_WorkloadState) String() string
- func (WasmDeploymentStatus_WorkloadState) Type() protoreflect.EnumType
- type WasmDeploymentTransitionFunction
- type WasmDeploymentWriter
- type WasmFilterSpec
- func (*WasmFilterSpec) Descriptor() ([]byte, []int)deprecated
- func (x *WasmFilterSpec) GetDynamicFilterConfig() string
- func (m *WasmFilterSpec) GetFilterConfigSource() isWasmFilterSpec_FilterConfigSource
- func (x *WasmFilterSpec) GetFilterContext() v1alpha3.EnvoyFilter_PatchContext
- func (m *WasmFilterSpec) GetFilterSource() isWasmFilterSpec_FilterSource
- func (x *WasmFilterSpec) GetHttpUriSource() *UriSource
- func (x *WasmFilterSpec) GetInsertBeforeFilter() string
- func (x *WasmFilterSpec) GetLocalPathSource() string
- func (x *WasmFilterSpec) GetRootId() string
- func (x *WasmFilterSpec) GetStaticFilterConfig() *any.Any
- func (x *WasmFilterSpec) GetVmId() string
- func (x *WasmFilterSpec) GetWasmImageSource() *WasmImageSource
- func (*WasmFilterSpec) ProtoMessage()
- func (x *WasmFilterSpec) ProtoReflect() protoreflect.Message
- func (x *WasmFilterSpec) Reset()
- func (x *WasmFilterSpec) String() string
- type WasmFilterSpec_DynamicFilterConfig
- type WasmFilterSpec_HttpUriSource
- type WasmFilterSpec_LocalPathSource
- type WasmFilterSpec_StaticFilterConfig
- type WasmFilterSpec_WasmImageSource
- type WasmImageSource
Constants ¶
This section is empty.
Variables ¶
var ( // SchemeGroupVersion is group version used to register these objects SchemeGroupVersion = schema.GroupVersion{Group: "networking.enterprise.mesh.gloo.solo.io", Version: "v1alpha1"} // SchemeBuilder is used to add go types to the GroupVersionKind scheme SchemeBuilder = &scheme.Builder{GroupVersion: SchemeGroupVersion} )
var ( WasmDeploymentStatus_WorkloadState_name = map[int32]string{ 0: "DEPLOYMENT_PENDING", 1: "FILTERS_DEPLOYED", 2: "DEPLOYMENT_FAILED", } WasmDeploymentStatus_WorkloadState_value = map[string]int32{ "DEPLOYMENT_PENDING": 0, "FILTERS_DEPLOYED": 1, "DEPLOYMENT_FAILED": 2, } )
Enum value maps for WasmDeploymentStatus_WorkloadState.
var File_github_com_solo_io_gloo_mesh_api_enterprise_networking_v1alpha1_wasm_deployment_proto protoreflect.FileDescriptor
var WasmDeploymentGVK = schema.GroupVersionKind{
Group: "networking.enterprise.mesh.gloo.solo.io",
Version: "v1alpha1",
Kind: "WasmDeployment",
}
GroupVersionKind for WasmDeployment
Functions ¶
func AddToScheme ¶
func NewWasmDeploymentClient ¶
func Resource ¶
func Resource(resource string) schema.GroupResource
Resource takes an unqualified resource and returns a Group qualified GroupResource
Types ¶
type Clientset ¶
type Clientset interface { // clienset for the networking.enterprise.mesh.gloo.solo.io/v1alpha1/v1alpha1 APIs WasmDeployments() WasmDeploymentClient }
clienset for the networking.enterprise.mesh.gloo.solo.io/v1alpha1 APIs
func NewClientset ¶
type ImagePullOptions ¶
type ImagePullOptions struct { // if a username/password is required, // specify here the name of a secret: // with keys: // * username: <username> // * password: <password> // // the secret must live in the WASM Cache Agent namespace // as the FilterDeployment PullSecret string `protobuf:"bytes,1,opt,name=pullSecret,proto3" json:"pullSecret,omitempty"` // skip verifying the image server's TLS certificate InsecureSkipVerify bool `protobuf:"varint,2,opt,name=insecureSkipVerify,proto3" json:"insecureSkipVerify,omitempty"` // use HTTP instead of HTTPS PlainHttp bool `protobuf:"varint,3,opt,name=plainHttp,proto3" json:"plainHttp,omitempty"` // contains filtered or unexported fields }
NOTE: ImagePullOptions are currently unsupported
func (*ImagePullOptions) Descriptor
deprecated
func (*ImagePullOptions) Descriptor() ([]byte, []int)
Deprecated: Use ImagePullOptions.ProtoReflect.Descriptor instead.
func (*ImagePullOptions) GetInsecureSkipVerify ¶
func (x *ImagePullOptions) GetInsecureSkipVerify() bool
func (*ImagePullOptions) GetPlainHttp ¶
func (x *ImagePullOptions) GetPlainHttp() bool
func (*ImagePullOptions) GetPullSecret ¶
func (x *ImagePullOptions) GetPullSecret() string
func (*ImagePullOptions) ProtoMessage ¶
func (*ImagePullOptions) ProtoMessage()
func (*ImagePullOptions) ProtoReflect ¶
func (x *ImagePullOptions) ProtoReflect() protoreflect.Message
func (*ImagePullOptions) Reset ¶
func (x *ImagePullOptions) Reset()
func (*ImagePullOptions) String ¶
func (x *ImagePullOptions) String() string
type MulticlusterClientset ¶
type MulticlusterClientset interface { // Cluster returns a Clientset for the given cluster Cluster(cluster string) (Clientset, error) }
MulticlusterClientset for the networking.enterprise.mesh.gloo.solo.io/v1alpha1 APIs
func NewMulticlusterClientset ¶
func NewMulticlusterClientset(client multicluster.Client) MulticlusterClientset
type MulticlusterWasmDeploymentClient ¶
type MulticlusterWasmDeploymentClient interface { // Cluster returns a WasmDeploymentClient for the given cluster Cluster(cluster string) (WasmDeploymentClient, error) }
Provides WasmDeploymentClients for multiple clusters.
func NewMulticlusterWasmDeploymentClient ¶
func NewMulticlusterWasmDeploymentClient(client multicluster.Client) MulticlusterWasmDeploymentClient
type UriSource ¶
type UriSource struct { // The HTTP URI from which to fetch the filter Uri string `protobuf:"bytes,1,opt,name=uri,proto3" json:"uri,omitempty"` // The Sha256 Checksum of the filter binary (will be verified by the proxy). // Required. Sha string `protobuf:"bytes,2,opt,name=sha,proto3" json:"sha,omitempty"` // contains filtered or unexported fields }
Specifies options for fetching WASM Filters from an HTTP URI.
func (*UriSource) Descriptor
deprecated
func (*UriSource) ProtoMessage ¶
func (*UriSource) ProtoMessage()
func (*UriSource) ProtoReflect ¶
func (x *UriSource) ProtoReflect() protoreflect.Message
type WasmDeployment ¶
type WasmDeployment struct { metav1.TypeMeta `json:",inline"` metav1.ObjectMeta `json:"metadata,omitempty"` Spec WasmDeploymentSpec `json:"spec,omitempty"` Status WasmDeploymentStatus `json:"status,omitempty"` }
WasmDeployment is the Schema for the wasmDeployment API
func (*WasmDeployment) DeepCopy ¶
func (in *WasmDeployment) DeepCopy() *WasmDeployment
func (*WasmDeployment) DeepCopyInto ¶
func (in *WasmDeployment) DeepCopyInto(out *WasmDeployment)
func (*WasmDeployment) DeepCopyObject ¶
func (in *WasmDeployment) DeepCopyObject() runtime.Object
func (WasmDeployment) GVK ¶
func (WasmDeployment) GVK() schema.GroupVersionKind
GVK returns the GroupVersionKind associated with the resource type.
type WasmDeploymentClient ¶
type WasmDeploymentClient interface { WasmDeploymentReader WasmDeploymentWriter WasmDeploymentStatusWriter }
Client knows how to perform CRUD operations on WasmDeployments.
type WasmDeploymentList ¶
type WasmDeploymentList struct { metav1.TypeMeta `json:",inline"` metav1.ListMeta `json:"metadata,omitempty"` Items []WasmDeployment `json:"items"` }
WasmDeploymentList contains a list of WasmDeployment
func (*WasmDeploymentList) DeepCopy ¶
func (in *WasmDeploymentList) DeepCopy() *WasmDeploymentList
func (*WasmDeploymentList) DeepCopyInto ¶
func (in *WasmDeploymentList) DeepCopyInto(out *WasmDeploymentList)
func (*WasmDeploymentList) DeepCopyObject ¶
func (in *WasmDeploymentList) DeepCopyObject() runtime.Object
type WasmDeploymentReader ¶
type WasmDeploymentReader interface { // Get retrieves a WasmDeployment for the given object key GetWasmDeployment(ctx context.Context, key client.ObjectKey) (*WasmDeployment, error) // List retrieves list of WasmDeployments for a given namespace and list options. ListWasmDeployment(ctx context.Context, opts ...client.ListOption) (*WasmDeploymentList, error) }
Reader knows how to read and list WasmDeployments.
type WasmDeploymentSlice ¶
type WasmDeploymentSlice []*WasmDeployment
WasmDeploymentSlice represents a slice of *WasmDeployment
type WasmDeploymentSpec ¶
type WasmDeploymentSpec struct { // //Sidecars/Gateways whose Workloads match these selectors will attach the specified WASM Filters. //Leave empty to have all workloads in the mesh apply receive the WASM Filter. WorkloadSelector []*v1alpha2.WorkloadSelector `protobuf:"bytes,1,rep,name=workload_selector,json=workloadSelector,proto3" json:"workload_selector,omitempty"` // Parameters for specifying the WASM filter Filters []*WasmFilterSpec `protobuf:"bytes,2,rep,name=filters,proto3" json:"filters,omitempty"` // weight is used to determine the order of WASM Filters when applying // multiple WasmDeployments to a single workload. // Deployed WASM filters will be sorted in order of // highest to lowest weight. WasmDeployments with equal weights will be // sorted non-deterministically. // Note that all WASM Filters are currently inserted just before the Envoy router filter // in the HTTP Connection Manager's HTTP Filter Chain. Weight uint32 `protobuf:"varint,3,opt,name=weight,proto3" json:"weight,omitempty"` // contains filtered or unexported fields }
A WasmDeployment deploys one or more WASM Envoy Filters to selected Sidecars and Gateways in a Mesh.
func (*WasmDeploymentSpec) DeepCopyInto ¶
func (in *WasmDeploymentSpec) DeepCopyInto(out *WasmDeploymentSpec)
DeepCopyInto for the WasmDeployment.Spec
func (*WasmDeploymentSpec) Descriptor
deprecated
func (*WasmDeploymentSpec) Descriptor() ([]byte, []int)
Deprecated: Use WasmDeploymentSpec.ProtoReflect.Descriptor instead.
func (*WasmDeploymentSpec) GetFilters ¶
func (x *WasmDeploymentSpec) GetFilters() []*WasmFilterSpec
func (*WasmDeploymentSpec) GetWeight ¶
func (x *WasmDeploymentSpec) GetWeight() uint32
func (*WasmDeploymentSpec) GetWorkloadSelector ¶
func (x *WasmDeploymentSpec) GetWorkloadSelector() []*v1alpha2.WorkloadSelector
func (*WasmDeploymentSpec) MarshalJSON ¶
func (this *WasmDeploymentSpec) MarshalJSON() ([]byte, error)
MarshalJSON is a custom marshaler for WasmDeploymentSpec
func (*WasmDeploymentSpec) ProtoMessage ¶
func (*WasmDeploymentSpec) ProtoMessage()
func (*WasmDeploymentSpec) ProtoReflect ¶
func (x *WasmDeploymentSpec) ProtoReflect() protoreflect.Message
func (*WasmDeploymentSpec) Reset ¶
func (x *WasmDeploymentSpec) Reset()
func (*WasmDeploymentSpec) String ¶
func (x *WasmDeploymentSpec) String() string
func (*WasmDeploymentSpec) UnmarshalJSON ¶
func (this *WasmDeploymentSpec) UnmarshalJSON(b []byte) error
UnmarshalJSON is a custom unmarshaler for WasmDeploymentSpec
type WasmDeploymentStatus ¶
type WasmDeploymentStatus struct { // The most recent generation observed in the the WasmDeployment metadata. // if the observedGeneration does not match generation, the controller has not received the most // recent version of this resource. ObservedGeneration int64 `protobuf:"varint,1,opt,name=observed_generation,json=observedGeneration,proto3" json:"observed_generation,omitempty"` // Any errors encountered while processing this generation of the resource. // This can include failures to pull a WASM image as well as missing or invalid // fields in the spec. Error string `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty"` // the state of the WasmDeployment as it has been applied to each individual workload. WorkloadStates map[string]WasmDeploymentStatus_WorkloadState `` /* 272-byte string literal not displayed */ // contains filtered or unexported fields }
func (*WasmDeploymentStatus) DeepCopyInto ¶
func (in *WasmDeploymentStatus) DeepCopyInto(out *WasmDeploymentStatus)
DeepCopyInto for the WasmDeployment.Status
func (*WasmDeploymentStatus) Descriptor
deprecated
func (*WasmDeploymentStatus) Descriptor() ([]byte, []int)
Deprecated: Use WasmDeploymentStatus.ProtoReflect.Descriptor instead.
func (*WasmDeploymentStatus) GetError ¶
func (x *WasmDeploymentStatus) GetError() string
func (*WasmDeploymentStatus) GetObservedGeneration ¶
func (x *WasmDeploymentStatus) GetObservedGeneration() int64
func (*WasmDeploymentStatus) GetWorkloadStates ¶
func (x *WasmDeploymentStatus) GetWorkloadStates() map[string]WasmDeploymentStatus_WorkloadState
func (*WasmDeploymentStatus) MarshalJSON ¶
func (this *WasmDeploymentStatus) MarshalJSON() ([]byte, error)
MarshalJSON is a custom marshaler for WasmDeploymentStatus
func (*WasmDeploymentStatus) ProtoMessage ¶
func (*WasmDeploymentStatus) ProtoMessage()
func (*WasmDeploymentStatus) ProtoReflect ¶
func (x *WasmDeploymentStatus) ProtoReflect() protoreflect.Message
func (*WasmDeploymentStatus) Reset ¶
func (x *WasmDeploymentStatus) Reset()
func (*WasmDeploymentStatus) String ¶
func (x *WasmDeploymentStatus) String() string
func (*WasmDeploymentStatus) UnmarshalJSON ¶
func (this *WasmDeploymentStatus) UnmarshalJSON(b []byte) error
UnmarshalJSON is a custom unmarshaler for WasmDeploymentStatus
type WasmDeploymentStatusWriter ¶
type WasmDeploymentStatusWriter interface { // Update updates the fields corresponding to the status subresource for the // given WasmDeployment object. UpdateWasmDeploymentStatus(ctx context.Context, obj *WasmDeployment, opts ...client.UpdateOption) error // Patch patches the given WasmDeployment object's subresource. PatchWasmDeploymentStatus(ctx context.Context, obj *WasmDeployment, patch client.Patch, opts ...client.PatchOption) error }
StatusWriter knows how to update status subresource of a WasmDeployment object.
type WasmDeploymentStatus_WorkloadState ¶
type WasmDeploymentStatus_WorkloadState int32
WorkloadState is the state of the WasmDeployment resource as it has been applied to an individual workload.
const ( // DEPLOYMENT_PENDING filters have not yet been deployed to the target workload. WasmDeploymentStatus_DEPLOYMENT_PENDING WasmDeploymentStatus_WorkloadState = 0 // FILTERS_DEPLOYED indicates the WASM Filters have been deployed to the target workload (along with any cluster dependencies). WasmDeploymentStatus_FILTERS_DEPLOYED WasmDeploymentStatus_WorkloadState = 1 // DEPLOYMENT_FAILED indicates Deploying the WASM Filters to this workload failed WasmDeploymentStatus_DEPLOYMENT_FAILED WasmDeploymentStatus_WorkloadState = 2 )
func (WasmDeploymentStatus_WorkloadState) Descriptor ¶
func (WasmDeploymentStatus_WorkloadState) Descriptor() protoreflect.EnumDescriptor
func (WasmDeploymentStatus_WorkloadState) Enum ¶
func (x WasmDeploymentStatus_WorkloadState) Enum() *WasmDeploymentStatus_WorkloadState
func (WasmDeploymentStatus_WorkloadState) EnumDescriptor
deprecated
func (WasmDeploymentStatus_WorkloadState) EnumDescriptor() ([]byte, []int)
Deprecated: Use WasmDeploymentStatus_WorkloadState.Descriptor instead.
func (WasmDeploymentStatus_WorkloadState) Number ¶
func (x WasmDeploymentStatus_WorkloadState) Number() protoreflect.EnumNumber
func (WasmDeploymentStatus_WorkloadState) String ¶
func (x WasmDeploymentStatus_WorkloadState) String() string
func (WasmDeploymentStatus_WorkloadState) Type ¶
func (WasmDeploymentStatus_WorkloadState) Type() protoreflect.EnumType
type WasmDeploymentTransitionFunction ¶
type WasmDeploymentTransitionFunction func(existing, desired *WasmDeployment) error
WasmDeploymentTransitionFunction instructs the WasmDeploymentWriter how to transition between an existing WasmDeployment object and a desired on an Upsert
type WasmDeploymentWriter ¶
type WasmDeploymentWriter interface { // Create saves the WasmDeployment object. CreateWasmDeployment(ctx context.Context, obj *WasmDeployment, opts ...client.CreateOption) error // Delete deletes the WasmDeployment object. DeleteWasmDeployment(ctx context.Context, key client.ObjectKey, opts ...client.DeleteOption) error // Update updates the given WasmDeployment object. UpdateWasmDeployment(ctx context.Context, obj *WasmDeployment, opts ...client.UpdateOption) error // Patch patches the given WasmDeployment object. PatchWasmDeployment(ctx context.Context, obj *WasmDeployment, patch client.Patch, opts ...client.PatchOption) error // DeleteAllOf deletes all WasmDeployment objects matching the given options. DeleteAllOfWasmDeployment(ctx context.Context, opts ...client.DeleteAllOfOption) error // Create or Update the WasmDeployment object. UpsertWasmDeployment(ctx context.Context, obj *WasmDeployment, transitionFuncs ...WasmDeploymentTransitionFunction) error }
Writer knows how to create, delete, and update WasmDeployments.
type WasmFilterSpec ¶
type WasmFilterSpec struct { // Several options are available for providing a source of the WASM filter file. // An option must be specified in order to execute the WasmDeployment. // // Types that are assignable to FilterSource: // *WasmFilterSpec_LocalPathSource // *WasmFilterSpec_HttpUriSource // *WasmFilterSpec_WasmImageSource FilterSource isWasmFilterSpec_FilterSource `protobuf_oneof:"filter_source"` // Filter/service configuration used to configure or reconfigure a filter // (proxy_on_configuration). // Several options are available for providing a source of filter config (dynamic and static)/ // // Types that are assignable to FilterConfigSource: // *WasmFilterSpec_StaticFilterConfig // *WasmFilterSpec_DynamicFilterConfig FilterConfigSource isWasmFilterSpec_FilterConfigSource `protobuf_oneof:"filter_config_source"` // the root id must match the root id // defined inside the filter. // if the user does not provide this field, // Gloo Mesh will attempt to pull the image // and set it from the filter_conf contained in the image config. // note that if the filter_source is not set to wasm_image_source, // this field is required RootId string `protobuf:"bytes,5,opt,name=root_id,json=rootId,proto3" json:"root_id,omitempty"` // An ID which will be used along with a hash of the wasm code // (or the name of the registered Null VM plugin) to determine which VM will be used to load the WASM filter. // All filters on the same proxy which use the same vm_id and code within will use the same VM. // May be left blank. Sharing a VM between plugins can reduce memory utilization and make sharing of data easier which may have security implications. VmId string `protobuf:"bytes,6,opt,name=vm_id,json=vmId,proto3" json:"vm_id,omitempty"` // The specific config generation context to which to attach the filter. Istio // generates envoy configuration in the context of a gateway, // inbound traffic to sidecar and outbound traffic from sidecar. // Uses the Istio default (ANY). FilterContext v1alpha3.EnvoyFilter_PatchContext `` /* 157-byte string literal not displayed */ // The filter in the Envoy HTTP Filter Chain immediately before which the WASM filter will be // inserted. // Defaults to `envoy.router`. InsertBeforeFilter string `protobuf:"bytes,9,opt,name=insert_before_filter,json=insertBeforeFilter,proto3" json:"insert_before_filter,omitempty"` // contains filtered or unexported fields }
description of the WASM Filter to deploy
func (*WasmFilterSpec) Descriptor
deprecated
func (*WasmFilterSpec) Descriptor() ([]byte, []int)
Deprecated: Use WasmFilterSpec.ProtoReflect.Descriptor instead.
func (*WasmFilterSpec) GetDynamicFilterConfig ¶
func (x *WasmFilterSpec) GetDynamicFilterConfig() string
func (*WasmFilterSpec) GetFilterConfigSource ¶
func (m *WasmFilterSpec) GetFilterConfigSource() isWasmFilterSpec_FilterConfigSource
func (*WasmFilterSpec) GetFilterContext ¶
func (x *WasmFilterSpec) GetFilterContext() v1alpha3.EnvoyFilter_PatchContext
func (*WasmFilterSpec) GetFilterSource ¶
func (m *WasmFilterSpec) GetFilterSource() isWasmFilterSpec_FilterSource
func (*WasmFilterSpec) GetHttpUriSource ¶
func (x *WasmFilterSpec) GetHttpUriSource() *UriSource
func (*WasmFilterSpec) GetInsertBeforeFilter ¶
func (x *WasmFilterSpec) GetInsertBeforeFilter() string
func (*WasmFilterSpec) GetLocalPathSource ¶
func (x *WasmFilterSpec) GetLocalPathSource() string
func (*WasmFilterSpec) GetRootId ¶
func (x *WasmFilterSpec) GetRootId() string
func (*WasmFilterSpec) GetStaticFilterConfig ¶
func (x *WasmFilterSpec) GetStaticFilterConfig() *any.Any
func (*WasmFilterSpec) GetVmId ¶
func (x *WasmFilterSpec) GetVmId() string
func (*WasmFilterSpec) GetWasmImageSource ¶
func (x *WasmFilterSpec) GetWasmImageSource() *WasmImageSource
func (*WasmFilterSpec) ProtoMessage ¶
func (*WasmFilterSpec) ProtoMessage()
func (*WasmFilterSpec) ProtoReflect ¶
func (x *WasmFilterSpec) ProtoReflect() protoreflect.Message
func (*WasmFilterSpec) Reset ¶
func (x *WasmFilterSpec) Reset()
func (*WasmFilterSpec) String ¶
func (x *WasmFilterSpec) String() string
type WasmFilterSpec_DynamicFilterConfig ¶
type WasmFilterSpec_DynamicFilterConfig struct { // Provide configuration from a dynamic configuration source. // This is used to connect proxies to a user-provided configuration server // rather than using the WasmDeployment CR to update filter configuration. // NOTE: Not currently implemented. This field serves as a placeholder. // passing it to the plugin. `google.protobuf.BytesValue` and // `google.protobuf.StringValue` are passed directly without the wrapper. // TODO(ilackarms): implement with dynamic filter config source (FCDS) https://github.com/envoyproxy/envoy/issues/7867 DynamicFilterConfig string `protobuf:"bytes,8,opt,name=dynamic_filter_config,json=dynamicFilterConfig,proto3,oneof"` }
type WasmFilterSpec_HttpUriSource ¶
type WasmFilterSpec_HttpUriSource struct { // Select `http_uri_source` to deploy the filter from an HTTP/S URI accessible // to the workload proxy. Note that Gloo Mesh cannot verify // whether the target workload proxy containers have HTTP accesss the given URI. // If filters do not load, please inspect the sidecar proxy logs. // TODO(ilackarms): see if we can somehow verify the filter exists in the proxy container and surface that on the WasmDeployment status // TODO(ilackarms): we may need to provide options for customizing the Cluster given to envoy along with the HTTP Fetch URI. currently Gloo Mesh will create a simple plaintext HTTP cluster from the Host/Port specified in the URI. HttpUriSource *UriSource `protobuf:"bytes,2,opt,name=http_uri_source,json=httpUriSource,proto3,oneof"` }
type WasmFilterSpec_LocalPathSource ¶
type WasmFilterSpec_LocalPathSource struct { // Select `local_path_source` to deploy the filter from a file accessible // to the workload proxy. Note that Gloo Mesh cannot verify // whether the target workload proxy containers contain the given path. // If filters do not load, please inspect the sidecar proxy logs. // TODO(ilackarms): see if we can somehow verify the filter exists in the proxy container and surface that on the WasmDeployment status LocalPathSource string `protobuf:"bytes,1,opt,name=local_path_source,json=localPathSource,proto3,oneof"` }
type WasmFilterSpec_StaticFilterConfig ¶
type WasmFilterSpec_StaticFilterConfig struct { // Provide configuration as a static // `google.protobuf.Struct` is serialized as JSON before // passing it to the plugin. `google.protobuf.BytesValue` and // `google.protobuf.StringValue` are passed directly without the wrapper. StaticFilterConfig *any.Any `protobuf:"bytes,4,opt,name=static_filter_config,json=staticFilterConfig,proto3,oneof"` }
type WasmFilterSpec_WasmImageSource ¶
type WasmFilterSpec_WasmImageSource struct { // fetch the image from a [WASM OCI Registry](https://webassemblyhub.io/) // Images can be built and pushed to registries using `meshctl` and `wasme`. WasmImageSource *WasmImageSource `protobuf:"bytes,3,opt,name=wasm_image_source,json=wasmImageSource,proto3,oneof"` }
type WasmImageSource ¶
type WasmImageSource struct { // the full tag of the wasm image. should include the registry address at the beginning, e.g. webassemblyhub.io/ilackarms/helloworld:v0.1 WasmImageTag string `protobuf:"bytes,1,opt,name=wasm_image_tag,json=wasmImageTag,proto3" json:"wasm_image_tag,omitempty"` // contains filtered or unexported fields }
Specifies options for fetching WASM Filters from a [WASM-compatible OCI Registry](https://webassemblyhub.io/) Images can be built and pushed to registries using `meshctl` and `wasme`.
func (*WasmImageSource) Descriptor
deprecated
func (*WasmImageSource) Descriptor() ([]byte, []int)
Deprecated: Use WasmImageSource.ProtoReflect.Descriptor instead.
func (*WasmImageSource) GetWasmImageTag ¶
func (x *WasmImageSource) GetWasmImageTag() string
func (*WasmImageSource) ProtoMessage ¶
func (*WasmImageSource) ProtoMessage()
func (*WasmImageSource) ProtoReflect ¶
func (x *WasmImageSource) ProtoReflect() protoreflect.Message
func (*WasmImageSource) Reset ¶
func (x *WasmImageSource) Reset()
func (*WasmImageSource) String ¶
func (x *WasmImageSource) String() string
Source Files ¶
Directories ¶
Path | Synopsis |
---|---|
Definitions for the Kubernetes Controllers Definitions for the multicluster Kubernetes Controllers Definitions for the Kubernetes Controllers
|
Definitions for the Kubernetes Controllers Definitions for the multicluster Kubernetes Controllers Definitions for the Kubernetes Controllers |
mocks
Package mock_controller is a generated GoMock package.
|
Package mock_controller is a generated GoMock package. |
Package mock_v1alpha1 is a generated GoMock package.
|
Package mock_v1alpha1 is a generated GoMock package. |
mocks
Package mock_v1alpha1sets is a generated GoMock package.
|
Package mock_v1alpha1sets is a generated GoMock package. |