v1alpha1

package
v0.8.1 Latest Latest
Warning

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

 Go to latest Published: Aug 7, 2020 License: Apache-2.0 Imports: 24 Imported by: 7

Documentation

Overview

Package v1alpha1 contains API Schema definitions for the multicluster.solo.io v1alpha1 API group +k8s:deepcopy-gen=package,register +groupName=multicluster.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

Constants

This section is empty.

Variables

View Source 
var (
	ClusterMarshaler   = &github_com_gogo_protobuf_jsonpb.Marshaler{}
	ClusterUnmarshaler = &github_com_gogo_protobuf_jsonpb.Unmarshaler{}
)
View Source 
var (
	// SchemeGroupVersion is group version used to register these objects
	SchemeGroupVersion = schema.GroupVersion{Group: "multicluster.solo.io", Version: "v1alpha1"}

	// SchemeBuilder is used to add go types to the GroupVersionKind scheme
	SchemeBuilder = &scheme.Builder{GroupVersion: SchemeGroupVersion}
)

Functions

func AddToScheme 

func AddToScheme(s *runtime.Scheme) error

func NewKubernetesClusterClient 

func NewKubernetesClusterClient(client client.Client) *kubernetesClusterClient

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 multicluster.solo.io/v1alpha1/v1alpha1 APIs
	KubernetesClusters() KubernetesClusterClient
}

clienset for the multicluster.solo.io/v1alpha1 APIs

func NewClientset 

func NewClientset(client client.Client) Clientset

func NewClientsetFromConfig 

func NewClientsetFromConfig(cfg *rest.Config) (Clientset, error)

type KubernetesCluster 

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

	Spec   KubernetesClusterSpec   `json:"spec,omitempty"`
	Status KubernetesClusterStatus `json:"status,omitempty"`
}

KubernetesCluster is the Schema for the kubernetesCluster API

func (*KubernetesCluster) DeepCopy 

func (in *KubernetesCluster) DeepCopy() *KubernetesCluster

func (*KubernetesCluster) DeepCopyInto 

func (in *KubernetesCluster) DeepCopyInto(out *KubernetesCluster)

func (*KubernetesCluster) DeepCopyObject 

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

type KubernetesClusterClient 

type KubernetesClusterClient interface {
	KubernetesClusterReader
	KubernetesClusterWriter
	KubernetesClusterStatusWriter
}

Client knows how to perform CRUD operations on KubernetesClusters.

type KubernetesClusterList 

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

KubernetesClusterList contains a list of KubernetesCluster

func (*KubernetesClusterList) DeepCopy 

func (in *KubernetesClusterList) DeepCopy() *KubernetesClusterList

func (*KubernetesClusterList) DeepCopyInto 

func (in *KubernetesClusterList) DeepCopyInto(out *KubernetesClusterList)

func (*KubernetesClusterList) DeepCopyObject 

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

type KubernetesClusterReader 

type KubernetesClusterReader interface {
	// Get retrieves a KubernetesCluster for the given object key
	GetKubernetesCluster(ctx context.Context, key client.ObjectKey) (*KubernetesCluster, error)

	// List retrieves list of KubernetesClusters for a given namespace and list options.
	ListKubernetesCluster(ctx context.Context, opts ...client.ListOption) (*KubernetesClusterList, error)
}

Reader knows how to read and list KubernetesClusters.

type KubernetesClusterSlice 

type KubernetesClusterSlice []*KubernetesCluster

KubernetesClusterSlice represents a slice of *KubernetesCluster

type KubernetesClusterSpec 

type KubernetesClusterSpec struct {
	// name of the secret which contains the kubeconfig with information to connect to the remote cluster.
	SecretName string `protobuf:"bytes,1,opt,name=secret_name,json=secretName,proto3" json:"secret_name,omitempty"`
	// name local DNS suffix used by the cluster.
	// used for building FQDNs for in-cluster services
	// defaults to 'cluster.local'
	ClusterDomain        string   `protobuf:"bytes,2,opt,name=cluster_domain,json=clusterDomain,proto3" json:"cluster_domain,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Representation of a Kubernetes cluster that has been registered.

func (*KubernetesClusterSpec) DeepCopyInto 

func (in *KubernetesClusterSpec) DeepCopyInto(out *KubernetesClusterSpec)

DeepCopyInto for the KubernetesCluster.Spec

func (*KubernetesClusterSpec) Descriptor 

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

func (*KubernetesClusterSpec) Equal 

func (this *KubernetesClusterSpec) Equal(that interface{}) bool

func (*KubernetesClusterSpec) GetClusterDomain 

func (m *KubernetesClusterSpec) GetClusterDomain() string

func (*KubernetesClusterSpec) GetSecretName 

func (m *KubernetesClusterSpec) GetSecretName() string

func (*KubernetesClusterSpec) Hash 

func (m *KubernetesClusterSpec) Hash(hasher hash.Hash64) (uint64, error)

Hash function

func (*KubernetesClusterSpec) MarshalJSON 

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

MarshalJSON is a custom marshaler for KubernetesClusterSpec

func (*KubernetesClusterSpec) ProtoMessage 

func (*KubernetesClusterSpec) ProtoMessage()

func (*KubernetesClusterSpec) Reset 

func (m *KubernetesClusterSpec) Reset()

func (*KubernetesClusterSpec) String 

func (m *KubernetesClusterSpec) String() string

func (*KubernetesClusterSpec) UnmarshalJSON 

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

UnmarshalJSON is a custom unmarshaler for KubernetesClusterSpec

func (*KubernetesClusterSpec) XXX_DiscardUnknown 

func (m *KubernetesClusterSpec) XXX_DiscardUnknown()

func (*KubernetesClusterSpec) XXX_Marshal 

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

func (*KubernetesClusterSpec) XXX_Merge 

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

func (*KubernetesClusterSpec) XXX_Size 

func (m *KubernetesClusterSpec) XXX_Size() int

func (*KubernetesClusterSpec) XXX_Unmarshal 

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

type KubernetesClusterStatus 

type KubernetesClusterStatus struct {
	// List of statuses about the kubernetes cluster.
	// This list allows for multiple applications/pods to record their connection status.
	Status               []*v1.Status `protobuf:"bytes,1,rep,name=status,proto3" json:"status,omitempty"`
	XXX_NoUnkeyedLiteral struct{}     `json:"-"`
	XXX_unrecognized     []byte       `json:"-"`
	XXX_sizecache        int32        `json:"-"`
}

func (*KubernetesClusterStatus) DeepCopyInto 

func (in *KubernetesClusterStatus) DeepCopyInto(out *KubernetesClusterStatus)

DeepCopyInto for the KubernetesCluster.Status

func (*KubernetesClusterStatus) Descriptor 

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

func (*KubernetesClusterStatus) Equal 

func (this *KubernetesClusterStatus) Equal(that interface{}) bool

func (*KubernetesClusterStatus) GetStatus 

func (m *KubernetesClusterStatus) GetStatus() []*v1.Status

func (*KubernetesClusterStatus) Hash 

func (m *KubernetesClusterStatus) Hash(hasher hash.Hash64) (uint64, error)

Hash function

func (*KubernetesClusterStatus) MarshalJSON 

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

MarshalJSON is a custom marshaler for KubernetesClusterStatus

func (*KubernetesClusterStatus) ProtoMessage 

func (*KubernetesClusterStatus) ProtoMessage()

func (*KubernetesClusterStatus) Reset 

func (m *KubernetesClusterStatus) Reset()

func (*KubernetesClusterStatus) String 

func (m *KubernetesClusterStatus) String() string

func (*KubernetesClusterStatus) UnmarshalJSON 

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

UnmarshalJSON is a custom unmarshaler for KubernetesClusterStatus

func (*KubernetesClusterStatus) XXX_DiscardUnknown 

func (m *KubernetesClusterStatus) XXX_DiscardUnknown()

func (*KubernetesClusterStatus) XXX_Marshal 

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

func (*KubernetesClusterStatus) XXX_Merge 

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

func (*KubernetesClusterStatus) XXX_Size 

func (m *KubernetesClusterStatus) XXX_Size() int

func (*KubernetesClusterStatus) XXX_Unmarshal 

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

type KubernetesClusterStatusWriter 

type KubernetesClusterStatusWriter interface {
	// Update updates the fields corresponding to the status subresource for the
	// given KubernetesCluster object.
	UpdateKubernetesClusterStatus(ctx context.Context, obj *KubernetesCluster, opts ...client.UpdateOption) error

	// Patch patches the given KubernetesCluster object's subresource.
	PatchKubernetesClusterStatus(ctx context.Context, obj *KubernetesCluster, patch client.Patch, opts ...client.PatchOption) error
}

StatusWriter knows how to update status subresource of a KubernetesCluster object.

type KubernetesClusterTransitionFunction 

type KubernetesClusterTransitionFunction func(existing, desired *KubernetesCluster) error

KubernetesClusterTransitionFunction instructs the KubernetesClusterWriter how to transition between an existing KubernetesCluster object and a desired on an Upsert

type KubernetesClusterWriter 

type KubernetesClusterWriter interface {
	// Create saves the KubernetesCluster object.
	CreateKubernetesCluster(ctx context.Context, obj *KubernetesCluster, opts ...client.CreateOption) error

	// Delete deletes the KubernetesCluster object.
	DeleteKubernetesCluster(ctx context.Context, key client.ObjectKey, opts ...client.DeleteOption) error

	// Update updates the given KubernetesCluster object.
	UpdateKubernetesCluster(ctx context.Context, obj *KubernetesCluster, opts ...client.UpdateOption) error

	// Patch patches the given KubernetesCluster object.
	PatchKubernetesCluster(ctx context.Context, obj *KubernetesCluster, patch client.Patch, opts ...client.PatchOption) error

	// DeleteAllOf deletes all KubernetesCluster objects matching the given options.
	DeleteAllOfKubernetesCluster(ctx context.Context, opts ...client.DeleteAllOfOption) error

	// Create or Update the KubernetesCluster object.
	UpsertKubernetesCluster(ctx context.Context, obj *KubernetesCluster, transitionFuncs ...KubernetesClusterTransitionFunction) error
}

Writer knows how to create, delete, and update KubernetesClusters.

type MulticlusterClientset 

type MulticlusterClientset interface {
	// Cluster returns a Clientset for the given cluster
	Cluster(cluster string) (Clientset, error)
}

MulticlusterClientset for the multicluster.solo.io/v1alpha1 APIs

func NewMulticlusterClientset 

func NewMulticlusterClientset(client multicluster.Client) MulticlusterClientset

type MulticlusterKubernetesClusterClient 

type MulticlusterKubernetesClusterClient interface {
	// Cluster returns a KubernetesClusterClient for the given cluster
	Cluster(cluster string) (KubernetesClusterClient, error)
}

Provides KubernetesClusterClients for multiple clusters.

func NewMulticlusterKubernetesClusterClient 

func NewMulticlusterKubernetesClusterClient(client multicluster.Client) MulticlusterKubernetesClusterClient

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
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.

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.