resource

Documentation

Index

• type Clientset
• type DeploymentInterface
• type Factory
  • func NewFactory(clients Clientset) *Factory
  • func (f *Factory) CreateDeployment(config *acappsv1.DeploymentApplyConfiguration) *Resource
  • func (f *Factory) CreateNamespace(config *acapiv1.NamespaceApplyConfiguration) *Resource
  • func (f *Factory) CreatePersistentVolume(config *acapiv1.PersistentVolumeApplyConfiguration) *Resource
  • func (f Factory) CreatePersistentVolumeClaim(config *acapiv1.PersistentVolumeClaimApplyConfiguration) *Resource
  • func (f *Factory) CreateService(config *acapiv1.ServiceApplyConfiguration) *Resource
• type Key
  • func (k Key) String() string
• type NamespaceInterface
• type ObjectSpeccer
  • func (o *ObjectSpeccer) Spec(obj runtime.Object) (any, error)
• type PersistentVolumeClaimInterface
• type PersistentVolumeInterface
• type Resource
  • func (r *Resource) Apply(ctx context.Context, opts metav1.ApplyOptions) (runtime.Object, error)
  • func (r *Resource) Delete(ctx context.Context, opts metav1.DeleteOptions) error
  • func (r *Resource) Get(ctx context.Context, opts metav1.GetOptions) (runtime.Object, error)
  • func (r *Resource) Kind() string
  • func (r *Resource) Name() string
  • func (r *Resource) Watch(ctx context.Context, opts metav1.ListOptions) (watch.Interface, error)
• type ServiceInterface

Types

type Clientset

type Clientset interface {
	Namespaces() NamespaceInterface
	Deployments() DeploymentInterface
	Services() ServiceInterface
	PersistentVolumes() PersistentVolumeInterface
	PersistentVolumeClaims() PersistentVolumeClaimInterface
}

type DeploymentInterface

type DeploymentInterface interface {
	Apply(ctx context.Context, deployment *acappsv1.DeploymentApplyConfiguration, opts metav1.ApplyOptions) (*appsv1.Deployment, error)
	Get(ctx context.Context, name string, opts metav1.GetOptions) (*appsv1.Deployment, error)
	// contains filtered or unexported methods
}

type Factory

type Factory struct {
	// contains filtered or unexported fields
}

func NewFactory

func NewFactory(clients Clientset) *Factory

func (*Factory) CreateDeployment

func (f *Factory) CreateDeployment(config *acappsv1.DeploymentApplyConfiguration) *Resource

func (*Factory) CreateNamespace

func (f *Factory) CreateNamespace(config *acapiv1.NamespaceApplyConfiguration) *Resource

func (*Factory) CreatePersistentVolume

func (f *Factory) CreatePersistentVolume(config *acapiv1.PersistentVolumeApplyConfiguration) *Resource

func (Factory) CreatePersistentVolumeClaim

func (f Factory) CreatePersistentVolumeClaim(config *acapiv1.PersistentVolumeClaimApplyConfiguration) *Resource

func (*Factory) CreateService

func (f *Factory) CreateService(config *acapiv1.ServiceApplyConfiguration) *Resource

type Key

type Key int

const (
	Namespace Key = iota
	MessageBrokerDeployment
	MessageBrokerService
	GRPCServerDeployment
	GRPCServerService
	WorkerpoolDeployment
	WorkerpoolPV
	WorkerpoolPVC
)

func (Key) String

func (k Key) String() string

type NamespaceInterface

type NamespaceInterface interface {
	Apply(ctx context.Context, namespace *acapiv1.NamespaceApplyConfiguration, opts metav1.ApplyOptions) (*apiv1.Namespace, error)
	Get(ctx context.Context, name string, opts metav1.GetOptions) (*apiv1.Namespace, error)
	// contains filtered or unexported methods
}

type ObjectSpeccer

type ObjectSpeccer struct{}

func (*ObjectSpeccer) Spec

func (o *ObjectSpeccer) Spec(obj runtime.Object) (any, error)

type PersistentVolumeClaimInterface

type PersistentVolumeClaimInterface interface {
	Apply(ctx context.Context, pvc *acapiv1.PersistentVolumeClaimApplyConfiguration, opts metav1.ApplyOptions) (*apiv1.PersistentVolumeClaim, error)
	Get(ctx context.Context, name string, opts metav1.GetOptions) (*apiv1.PersistentVolumeClaim, error)
	// contains filtered or unexported methods
}

type PersistentVolumeInterface

type PersistentVolumeInterface interface {
	Apply(ctx context.Context, pv *acapiv1.PersistentVolumeApplyConfiguration, opts metav1.ApplyOptions) (*apiv1.PersistentVolume, error)
	Get(ctx context.Context, name string, opts metav1.GetOptions) (*apiv1.PersistentVolume, error)
	// contains filtered or unexported methods
}

type Resource

type Resource struct {
	// contains filtered or unexported fields
}

func (*Resource) Apply

func (r *Resource) Apply(ctx context.Context, opts metav1.ApplyOptions) (runtime.Object, error)

func (*Resource) Delete

func (r *Resource) Delete(ctx context.Context, opts metav1.DeleteOptions) error

func (*Resource) Get

func (r *Resource) Get(ctx context.Context, opts metav1.GetOptions) (runtime.Object, error)

func (*Resource) Kind

func (r *Resource) Kind() string

func (*Resource) Name

func (r *Resource) Name() string

func (*Resource) Watch

func (r *Resource) Watch(ctx context.Context, opts metav1.ListOptions) (watch.Interface, error)

type ServiceInterface

type ServiceInterface interface {
	Apply(ctx context.Context, service *acapiv1.ServiceApplyConfiguration, opts metav1.ApplyOptions) (*apiv1.Service, error)
	Get(ctx context.Context, name string, opts metav1.GetOptions) (*apiv1.Service, error)
	// contains filtered or unexported methods
}