service

package
v1.0.34 Latest Latest
Warning

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

 Go to latest Published: May 16, 2019 License: Apache-2.0 Imports: 24 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func Add 

func Add(mgr manager.Manager, kind runtime.Object, controllerName string) error

Add creates a new Auth Controller and adds it to the Manager with default RBAC. The Manager will set fields on the Controller and Start it when the Manager is Started. USER ACTION REQUIRED: update cmd/manager/main.go to call this iam.Add(mgr) to install this Controller

func GetAerospikeWrapper 

func GetAerospikeWrapper() v1.K8sObjectWrapper

func GetDeploymentWrapper 

func GetDeploymentWrapper() v1.K8sObjectWrapper

func GetIngressWrapper 

func GetIngressWrapper() v1.K8sObjectWrapper

func GetServiceWrapper 

func GetServiceWrapper() v1.K8sObjectWrapper

Types

type AerospikeInstance 

type AerospikeInstance interface {
	GetAsSpec() *AsSpec
	SetMinorVersion() error
}

type AerospikeWrapper 

type AerospikeWrapper struct {
	*v1.Aerospike
	AsSpec
	AerospikeInstance
}

AerospikeWrapper to abstract v1beta1.Aerospike

func (*AerospikeWrapper) GetK8sObj 

func (i *AerospikeWrapper) GetK8sObj() runtime.Object

GetK8sObj implementation for K8sObjectWrapper interface

func (*AerospikeWrapper) GetSpec 

func (i *AerospikeWrapper) GetSpec() *AsSpec

func (*AerospikeWrapper) ObjectsAreEqual 

func (i *AerospikeWrapper) ObjectsAreEqual(oldie interface{}) bool

ObjectsAreEqual implementation for K8sObjectWrapper interface, uses reflect.DeepEqual to compare Objects

func (*AerospikeWrapper) RegisterCRD 

func (i *AerospikeWrapper) RegisterCRD(config *rest.Config) error

SetK8sObj implementation for K8sObjectWrapper interface

func (*AerospikeWrapper) SetK8sObj 

func (i *AerospikeWrapper) SetK8sObj(obj runtime.Object)

SetK8sObj implementation for K8sObjectWrapper interface

func (*AerospikeWrapper) SetMinorVersion 

func (i *AerospikeWrapper) SetMinorVersion() error

type AsSpec 

type AsSpec struct {
	v1.AerospikeSpec
	CommonProps
}

type CommonProps 

type CommonProps struct {
	Name         string
	Namespace    string
	Version      string
	MajorVersion string
}

type DeployInstance 

type DeployInstance interface {
	GetSpec() *DeploySpec
	SetMinorVersion() error
}

type DeploySpec 

type DeploySpec struct {
	ReplicaCount string
	Env          []EnvVar
	MajorVersion string
	Namespace    string
	Name         string
	Version      string
	PullSecret   string
	Image        string
}

type DeploymentWrapper 

type DeploymentWrapper struct {
	*appsv1.Deployment
	DeploySpec
}

DeploymentWrapper to abstract appsv1.Deployment

func (*DeploymentWrapper) GetK8sObj 

func (d *DeploymentWrapper) GetK8sObj() runtime.Object

GetK8sObj implementation for K8sObjectWrapper interface

func (*DeploymentWrapper) GetSpec 

func (i *DeploymentWrapper) GetSpec() *DeploySpec

func (*DeploymentWrapper) ObjectsAreEqual 

func (d *DeploymentWrapper) ObjectsAreEqual(oldie interface{}) bool

ObjectsAreEqual implementation for K8sObjectWrapper interface, uses reflect.DeepEqual to compare Objects

func (*DeploymentWrapper) SetK8sObj 

func (d *DeploymentWrapper) SetK8sObj(obj runtime.Object)

SetK8sObj implementation for K8sObjectWrapper interface

func (*DeploymentWrapper) SetMinorVersion 

func (i *DeploymentWrapper) SetMinorVersion() error

type EnvVar 

type EnvVar struct {
	Name  string
	Value string
}

type IngressInstance 

type IngressInstance interface {
	GetSpec() *IngressSpec
	SetMajorVersion() error
}

type IngressSpec 

type IngressSpec struct {
	CommonProps
	IngressPath     string
	BaseURL         string
	GRPC            bool
	GRPCIngressPath string
}

type IngressWrapper 

type IngressWrapper struct {
	*v1beta1.Ingress
	IngressSpec
}

IngressWrapper to abstract v1beta1.Ingress

func (*IngressWrapper) GetK8sObj 

func (i *IngressWrapper) GetK8sObj() runtime.Object

GetK8sObj implementation for K8sObjectWrapper interface

func (*IngressWrapper) GetSpec 

func (i *IngressWrapper) GetSpec() *IngressSpec

func (*IngressWrapper) ObjectsAreEqual 

func (i *IngressWrapper) ObjectsAreEqual(oldie interface{}) bool

ObjectsAreEqual implementation for K8sObjectWrapper interface, uses reflect.DeepEqual to compare Objects

func (*IngressWrapper) SetK8sObj 

func (i *IngressWrapper) SetK8sObj(obj runtime.Object)

SetK8sObj implementation for K8sObjectWrapper interface

func (*IngressWrapper) SetMinorVersion 

func (i *IngressWrapper) SetMinorVersion() error

type Reconcile 

type Reconcile struct {
	client.Client
	// contains filtered or unexported fields
}

Reconcile reconciles a Auth object

func (*Reconcile) CreateAerospike 

func (r *Reconcile) CreateAerospike(inst interface{}) *AerospikeWrapper

func (*Reconcile) CreateDeployment 

func (r *Reconcile) CreateDeployment(request reconcile.Request, inst interface{}) *DeploymentWrapper

func (*Reconcile) CreateIngress 

func (r *Reconcile) CreateIngress(request reconcile.Request, inst interface{}) *IngressWrapper

func (*Reconcile) CreateService 

func (r *Reconcile) CreateService(request reconcile.Request, inst interface{}) *ServiceWrapper

func (*Reconcile) DeployRuntimeObject 

func (r *Reconcile) DeployRuntimeObject(request reconcile.Request, instance v1.K8sMetaObject, obj v1.K8sObjectWrapper) (reconcile.Result, error)

func (*Reconcile) GetFoundObject 

func (r *Reconcile) GetFoundObject(kind string) v1.K8sObjectWrapper

func (*Reconcile) Reconcile 

func (r *Reconcile) Reconcile(request reconcile.Request) (reconcile.Result, error)

Reconcile reads that state of the cluster for a Auth object and makes changes based on the state read and what is in the Auth.Spec TODO(user): Modify this Reconcile function to implement your Controller logic. The scaffolding writes a Deployment as an example Automatically generate RBAC rules to allow the Controller to read and write Deployments +kubebuilder:rbac:groups=apps,resources=deployments,verbs=get;list;watch;create;update;patch;delete +kubebuilder:rbac:groups=iam.rootd.ch,resources=samlConnectors,verbs=get;list;watch;create;update;patch;delete

type ServiceInstance 

type ServiceInstance interface {
	DeployInstance
	GetServiceSpec() *ServiceSpec
}

type ServiceSpec 

type ServiceSpec struct {
	CommonProps
	ServicePath     string
	BaseURL         string
	GRPC            bool
	GRPCServicePath string
	HttpsPort       int32
}

type ServiceWrapper 

type ServiceWrapper struct {
	*corev1.Service
	ServiceInstance
}

ServiceWrapper to abstract corev1.Service

func (*ServiceWrapper) GetK8sObj 

func (s *ServiceWrapper) GetK8sObj() runtime.Object

GetK8sObj implementation for K8sObjectWrapper interface

func (*ServiceWrapper) ObjectsAreEqual 

func (s *ServiceWrapper) ObjectsAreEqual(oldie interface{}) bool

ObjectsAreEqual implementation for K8sObjectWrapper interface, uses reflect.DeepEqual to compare Objects

func (*ServiceWrapper) SetK8sObj 

func (s *ServiceWrapper) SetK8sObj(obj runtime.Object)

SetK8sObj implementation for K8sObjectWrapper interface

func (*ServiceWrapper) SetMinorVersion 

func (i *ServiceWrapper) SetMinorVersion() 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.