v1

package
v0.0.26 Latest Latest
Warning

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

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

Documentation

Overview

Package v1 contains API Schema definitions for the wasme.io v1 API group +k8s:deepcopy-gen=package,register +groupName=wasme.io

NOTE: Boilerplate only. Ignore this file. Used to register the Go types with the Kubernetes internal scheme

Definitions for the Kubernetes types

Index

Constants

This section is empty.

Variables

View Source 
var (
	FilterDeploymentMarshaler   = &github_com_gogo_protobuf_jsonpb.Marshaler{}
	FilterDeploymentUnmarshaler = &github_com_gogo_protobuf_jsonpb.Unmarshaler{}
)
View Source 
var (
	// SchemeGroupVersion is group version used to register these objects
	SchemeGroupVersion = schema.GroupVersion{Group: "wasme.io", Version: "v1"}

	// SchemeBuilder is used to add go types to the GroupVersionKind scheme
	SchemeBuilder = &scheme.Builder{GroupVersion: SchemeGroupVersion}
)
View Source 
var WorkloadStatus_State_name = map[int32]string{
	0: "Pending",
	1: "Succeeded",
	2: "Failed",
}
View Source 
var WorkloadStatus_State_value = map[string]int32{
	"Pending":   0,
	"Succeeded": 1,
	"Failed":    2,
}

Functions

func AddToScheme 

func AddToScheme(s *runtime.Scheme) error

func Resource 

func Resource(resource string) schema.GroupResource

Resource takes an unqualified resource and returns a Group qualified GroupResource

Types

type DeploymentSpec 

type DeploymentSpec struct {
	// Types that are valid to be assigned to DeploymentType:
	//	*DeploymentSpec_Istio
	DeploymentType       isDeploymentSpec_DeploymentType `protobuf_oneof:"deploymentType"`
	XXX_NoUnkeyedLiteral struct{}                        `json:"-"`
	XXX_unrecognized     []byte                          `json:"-"`
	XXX_sizecache        int32                           `json:"-"`
}

how to deploy the filter

func (*DeploymentSpec) Descriptor 

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

func (*DeploymentSpec) GetDeploymentType 

func (m *DeploymentSpec) GetDeploymentType() isDeploymentSpec_DeploymentType

func (*DeploymentSpec) GetIstio 

func (m *DeploymentSpec) GetIstio() *IstioDeploymentSpec

func (*DeploymentSpec) MarshalJSON 

func (this *DeploymentSpec) MarshalJSON() ([]byte, error)

MarshalJSON is a custom marshaler for DeploymentSpec

func (*DeploymentSpec) ProtoMessage 

func (*DeploymentSpec) ProtoMessage()

func (*DeploymentSpec) Reset 

func (m *DeploymentSpec) Reset()

func (*DeploymentSpec) String 

func (m *DeploymentSpec) String() string

func (*DeploymentSpec) UnmarshalJSON 

func (this *DeploymentSpec) UnmarshalJSON(b []byte) error

UnmarshalJSON is a custom unmarshaler for DeploymentSpec

func (*DeploymentSpec) XXX_DiscardUnknown 

func (m *DeploymentSpec) XXX_DiscardUnknown()

func (*DeploymentSpec) XXX_Marshal 

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

func (*DeploymentSpec) XXX_Merge 

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

func (*DeploymentSpec) XXX_OneofWrappers 

func (*DeploymentSpec) XXX_OneofWrappers() []interface{}

XXX_OneofWrappers is for the internal use of the proto package.

func (*DeploymentSpec) XXX_Size 

func (m *DeploymentSpec) XXX_Size() int

func (*DeploymentSpec) XXX_Unmarshal 

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

type DeploymentSpec_Istio 

type DeploymentSpec_Istio struct {
	Istio *IstioDeploymentSpec `protobuf:"bytes,2,opt,name=istio,proto3,oneof" json:"istio,omitempty"`
}

type FilterDeployment 

type FilterDeployment struct {
	metav1.TypeMeta   `json:",inline"`
	metav1.ObjectMeta `json:"metadata,omitempty"`

	Spec   FilterDeploymentSpec   `json:"spec,omitempty"`
	Status FilterDeploymentStatus `json:"status,omitempty"`
}

FilterDeployment is the Schema for the filterDeployment API

func (*FilterDeployment) DeepCopy 

func (in *FilterDeployment) DeepCopy() *FilterDeployment

func (*FilterDeployment) DeepCopyInto 

func (in *FilterDeployment) DeepCopyInto(out *FilterDeployment)

func (*FilterDeployment) DeepCopyObject 

func (in *FilterDeployment) DeepCopyObject() runtime.Object

type FilterDeploymentList 

type FilterDeploymentList struct {
	metav1.TypeMeta `json:",inline"`
	metav1.ListMeta `json:"metadata,omitempty"`
	Items           []FilterDeployment `json:"items"`
}

FilterDeploymentList contains a list of FilterDeployment

func (*FilterDeploymentList) DeepCopy 

func (in *FilterDeploymentList) DeepCopy() *FilterDeploymentList

func (*FilterDeploymentList) DeepCopyInto 

func (in *FilterDeploymentList) DeepCopyInto(out *FilterDeploymentList)

func (*FilterDeploymentList) DeepCopyObject 

func (in *FilterDeploymentList) DeepCopyObject() runtime.Object

type FilterDeploymentSpec 

type FilterDeploymentSpec struct {
	// the spec of the filter to deploy
	Filter *FilterSpec `protobuf:"bytes,1,opt,name=filter,proto3" json:"filter,omitempty"`
	// Spec that selects one or more target workloads in the FilterDeployment namespace
	Deployment           *DeploymentSpec `protobuf:"bytes,2,opt,name=deployment,proto3" json:"deployment,omitempty"`
	XXX_NoUnkeyedLiteral struct{}        `json:"-"`
	XXX_unrecognized     []byte          `json:"-"`
	XXX_sizecache        int32           `json:"-"`
}

A FilterDeployment tells the Wasme Operator to deploy a filter with the provided configuration to the target workloads. Currently FilterDeployments support Wasm filters on Istio

func (*FilterDeploymentSpec) DeepCopyInto 

func (in *FilterDeploymentSpec) DeepCopyInto(out *FilterDeploymentSpec)

DeepCopyInto for the FilterDeployment.Spec

func (*FilterDeploymentSpec) Descriptor 

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

func (*FilterDeploymentSpec) GetDeployment 

func (m *FilterDeploymentSpec) GetDeployment() *DeploymentSpec

func (*FilterDeploymentSpec) GetFilter 

func (m *FilterDeploymentSpec) GetFilter() *FilterSpec

func (*FilterDeploymentSpec) MarshalJSON 

func (this *FilterDeploymentSpec) MarshalJSON() ([]byte, error)

MarshalJSON is a custom marshaler for FilterDeploymentSpec

func (*FilterDeploymentSpec) ProtoMessage 

func (*FilterDeploymentSpec) ProtoMessage()

func (*FilterDeploymentSpec) Reset 

func (m *FilterDeploymentSpec) Reset()

func (*FilterDeploymentSpec) String 

func (m *FilterDeploymentSpec) String() string

func (*FilterDeploymentSpec) UnmarshalJSON 

func (this *FilterDeploymentSpec) UnmarshalJSON(b []byte) error

UnmarshalJSON is a custom unmarshaler for FilterDeploymentSpec

func (*FilterDeploymentSpec) XXX_DiscardUnknown 

func (m *FilterDeploymentSpec) XXX_DiscardUnknown()

func (*FilterDeploymentSpec) XXX_Marshal 

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

func (*FilterDeploymentSpec) XXX_Merge 

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

func (*FilterDeploymentSpec) XXX_Size 

func (m *FilterDeploymentSpec) XXX_Size() int

func (*FilterDeploymentSpec) XXX_Unmarshal 

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

type FilterDeploymentStatus 

type FilterDeploymentStatus struct {
	// the observed generation of the FilterDeployment
	ObservedGeneration int64 `protobuf:"varint,1,opt,name=observedGeneration,proto3" json:"observedGeneration,omitempty"`
	// for each workload, was the deployment successful?
	Workloads map[string]*WorkloadStatus `` /* 159-byte string literal not displayed */
	// a human-readable string explaining the error, if any
	Reason               string   `protobuf:"bytes,3,opt,name=reason,proto3" json:"reason,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

the current status of the deployment

func (*FilterDeploymentStatus) DeepCopyInto 

func (in *FilterDeploymentStatus) DeepCopyInto(out *FilterDeploymentStatus)

DeepCopyInto for the FilterDeployment.Status

func (*FilterDeploymentStatus) Descriptor 

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

func (*FilterDeploymentStatus) GetObservedGeneration 

func (m *FilterDeploymentStatus) GetObservedGeneration() int64

func (*FilterDeploymentStatus) GetReason 

func (m *FilterDeploymentStatus) GetReason() string

func (*FilterDeploymentStatus) GetWorkloads 

func (m *FilterDeploymentStatus) GetWorkloads() map[string]*WorkloadStatus

func (*FilterDeploymentStatus) MarshalJSON 

func (this *FilterDeploymentStatus) MarshalJSON() ([]byte, error)

MarshalJSON is a custom marshaler for FilterDeploymentStatus

func (*FilterDeploymentStatus) ProtoMessage 

func (*FilterDeploymentStatus) ProtoMessage()

func (*FilterDeploymentStatus) Reset 

func (m *FilterDeploymentStatus) Reset()

func (*FilterDeploymentStatus) String 

func (m *FilterDeploymentStatus) String() string

func (*FilterDeploymentStatus) UnmarshalJSON 

func (this *FilterDeploymentStatus) UnmarshalJSON(b []byte) error

UnmarshalJSON is a custom unmarshaler for FilterDeploymentStatus

func (*FilterDeploymentStatus) XXX_DiscardUnknown 

func (m *FilterDeploymentStatus) XXX_DiscardUnknown()

func (*FilterDeploymentStatus) XXX_Marshal 

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

func (*FilterDeploymentStatus) XXX_Merge 

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

func (*FilterDeploymentStatus) XXX_Size 

func (m *FilterDeploymentStatus) XXX_Size() int

func (*FilterDeploymentStatus) XXX_Unmarshal 

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

type FilterSpec 

type FilterSpec struct {
	// unique identifier that will be used
	// to remove the filter as well as for logging.
	// if id is not set, it will be set automatically to be the name.namespace
	// of the FilterDeployment resource
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// name of image which houses the compiled wasm filter
	Image string `protobuf:"bytes,2,opt,name=image,proto3" json:"image,omitempty"`
	// Filter/service configuration used to configure or reconfigure a plugin
	// (proxy_on_configuration).
	// `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.
	Config *types.Any `protobuf:"bytes,3,opt,name=config,proto3" json:"config,omitempty"`
	// the root id must match the root id
	// defined inside the filter.
	// if the user does not provide this field,
	// wasme will attempt to pull the image
	// and set it from the filter_conf
	// the first time it must pull the image and inspect it
	// second time it will cache it locally
	// if the user provides
	RootID string `protobuf:"bytes,4,opt,name=rootID,proto3" json:"rootID,omitempty"`
	// custom options if pulling from private / custom repositories
	ImagePullOptions     *ImagePullOptions `protobuf:"bytes,5,opt,name=imagePullOptions,proto3" json:"imagePullOptions,omitempty"`
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

the filter to deploy

func (*FilterSpec) Descriptor 

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

func (*FilterSpec) GetConfig 

func (m *FilterSpec) GetConfig() *types.Any

func (*FilterSpec) GetId 

func (m *FilterSpec) GetId() string

func (*FilterSpec) GetImage 

func (m *FilterSpec) GetImage() string

func (*FilterSpec) GetImagePullOptions 

func (m *FilterSpec) GetImagePullOptions() *ImagePullOptions

func (*FilterSpec) GetRootID 

func (m *FilterSpec) GetRootID() string

func (*FilterSpec) MarshalJSON 

func (this *FilterSpec) MarshalJSON() ([]byte, error)

MarshalJSON is a custom marshaler for FilterSpec

func (*FilterSpec) ProtoMessage 

func (*FilterSpec) ProtoMessage()

func (*FilterSpec) Reset 

func (m *FilterSpec) Reset()

func (*FilterSpec) String 

func (m *FilterSpec) String() string

func (*FilterSpec) UnmarshalJSON 

func (this *FilterSpec) UnmarshalJSON(b []byte) error

UnmarshalJSON is a custom unmarshaler for FilterSpec

func (*FilterSpec) XXX_DiscardUnknown 

func (m *FilterSpec) XXX_DiscardUnknown()

func (*FilterSpec) XXX_Marshal 

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

func (*FilterSpec) XXX_Merge 

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

func (*FilterSpec) XXX_Size 

func (m *FilterSpec) XXX_Size() int

func (*FilterSpec) XXX_Unmarshal 

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

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 same 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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ImagePullOptions) Descriptor 

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

func (*ImagePullOptions) GetInsecureSkipVerify 

func (m *ImagePullOptions) GetInsecureSkipVerify() bool

func (*ImagePullOptions) GetPlainHttp 

func (m *ImagePullOptions) GetPlainHttp() bool

func (*ImagePullOptions) GetPullSecret 

func (m *ImagePullOptions) GetPullSecret() string

func (*ImagePullOptions) MarshalJSON 

func (this *ImagePullOptions) MarshalJSON() ([]byte, error)

MarshalJSON is a custom marshaler for ImagePullOptions

func (*ImagePullOptions) ProtoMessage 

func (*ImagePullOptions) ProtoMessage()

func (*ImagePullOptions) Reset 

func (m *ImagePullOptions) Reset()

func (*ImagePullOptions) String 

func (m *ImagePullOptions) String() string

func (*ImagePullOptions) UnmarshalJSON 

func (this *ImagePullOptions) UnmarshalJSON(b []byte) error

UnmarshalJSON is a custom unmarshaler for ImagePullOptions

func (*ImagePullOptions) XXX_DiscardUnknown 

func (m *ImagePullOptions) XXX_DiscardUnknown()

func (*ImagePullOptions) XXX_Marshal 

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

func (*ImagePullOptions) XXX_Merge 

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

func (*ImagePullOptions) XXX_Size 

func (m *ImagePullOptions) XXX_Size() int

func (*ImagePullOptions) XXX_Unmarshal 

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

type IstioDeploymentSpec 

type IstioDeploymentSpec struct {
	// the kind of workload to deploy the filter to
	// can either be Deployment or DaemonSet
	Kind string `protobuf:"bytes,1,opt,name=kind,proto3" json:"kind,omitempty"`
	// deploy the filter to workloads with these labels
	// the workload must live in the same namespace as the FilterDeployment
	// if empty, the filter will be deployed to all workloads in the namespace
	Labels map[string]string `` /* 153-byte string literal not displayed */
	// the namespace where the Istio control plane is installed.
	// defaults to `istio-system`.
	IstioNamespace       string   `protobuf:"bytes,3,opt,name=istioNamespace,proto3" json:"istioNamespace,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

how to deploy to Istio

func (*IstioDeploymentSpec) Descriptor 

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

func (*IstioDeploymentSpec) GetIstioNamespace 

func (m *IstioDeploymentSpec) GetIstioNamespace() string

func (*IstioDeploymentSpec) GetKind 

func (m *IstioDeploymentSpec) GetKind() string

func (*IstioDeploymentSpec) GetLabels added in v0.0.13 

func (m *IstioDeploymentSpec) GetLabels() map[string]string

func (*IstioDeploymentSpec) MarshalJSON 

func (this *IstioDeploymentSpec) MarshalJSON() ([]byte, error)

MarshalJSON is a custom marshaler for IstioDeploymentSpec

func (*IstioDeploymentSpec) ProtoMessage 

func (*IstioDeploymentSpec) ProtoMessage()

func (*IstioDeploymentSpec) Reset 

func (m *IstioDeploymentSpec) Reset()

func (*IstioDeploymentSpec) String 

func (m *IstioDeploymentSpec) String() string

func (*IstioDeploymentSpec) UnmarshalJSON 

func (this *IstioDeploymentSpec) UnmarshalJSON(b []byte) error

UnmarshalJSON is a custom unmarshaler for IstioDeploymentSpec

func (*IstioDeploymentSpec) XXX_DiscardUnknown 

func (m *IstioDeploymentSpec) XXX_DiscardUnknown()

func (*IstioDeploymentSpec) XXX_Marshal 

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

func (*IstioDeploymentSpec) XXX_Merge 

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

func (*IstioDeploymentSpec) XXX_Size 

func (m *IstioDeploymentSpec) XXX_Size() int

func (*IstioDeploymentSpec) XXX_Unmarshal 

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

type WorkloadStatus 

type WorkloadStatus struct {
	State WorkloadStatus_State `protobuf:"varint,1,opt,name=state,proto3,enum=wasme.io.WorkloadStatus_State" json:"state,omitempty"`
	// a human-readable string explaining the error, if any
	Reason               string   `protobuf:"bytes,2,opt,name=reason,proto3" json:"reason,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*WorkloadStatus) Descriptor 

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

func (*WorkloadStatus) GetReason 

func (m *WorkloadStatus) GetReason() string

func (*WorkloadStatus) GetState 

func (m *WorkloadStatus) GetState() WorkloadStatus_State

func (*WorkloadStatus) MarshalJSON 

func (this *WorkloadStatus) MarshalJSON() ([]byte, error)

MarshalJSON is a custom marshaler for WorkloadStatus

func (*WorkloadStatus) ProtoMessage 

func (*WorkloadStatus) ProtoMessage()

func (*WorkloadStatus) Reset 

func (m *WorkloadStatus) Reset()

func (*WorkloadStatus) String 

func (m *WorkloadStatus) String() string

func (*WorkloadStatus) UnmarshalJSON 

func (this *WorkloadStatus) UnmarshalJSON(b []byte) error

UnmarshalJSON is a custom unmarshaler for WorkloadStatus

func (*WorkloadStatus) XXX_DiscardUnknown 

func (m *WorkloadStatus) XXX_DiscardUnknown()

func (*WorkloadStatus) XXX_Marshal 

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

func (*WorkloadStatus) XXX_Merge 

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

func (*WorkloadStatus) XXX_Size 

func (m *WorkloadStatus) XXX_Size() int

func (*WorkloadStatus) XXX_Unmarshal 

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

type WorkloadStatus_State 

type WorkloadStatus_State int32

the state of the filter deployment 

const (
	WorkloadStatus_Pending   WorkloadStatus_State = 0
	WorkloadStatus_Succeeded WorkloadStatus_State = 1
	WorkloadStatus_Failed    WorkloadStatus_State = 2
)

func (WorkloadStatus_State) EnumDescriptor 

func (WorkloadStatus_State) EnumDescriptor() ([]byte, []int)

func (WorkloadStatus_State) String 

func (x WorkloadStatus_State) String() string

Source Files

View all 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

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.