kube

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

type BasicController struct {
	Container

	CreateOpts v1meta.CreateOptions
	DeleteOpts v1meta.DeleteOptions
	GetOpts    v1meta.GetOptions
	// contains filtered or unexported fields
}

type ClientSet interface {
	Namespace() string
	Client() *kubernetes.Clientset
	Namespaces() typedv1core.NamespaceInterface
	Deployments() typedv1apps.DeploymentInterface
	Ingresses() typedv1beta1net.IngressInterface
	Secrets() typedv1core.SecretInterface
	Services() typedv1core.ServiceInterface
	ConfigMaps() typedv1core.ConfigMapInterface
	PersistentVolumeClaims() typedv1core.PersistentVolumeClaimInterface
}

type Container interface {
	Kinds() []Kind                  // Kinds() should returns container Kind's
	Self() Container                // Self() returns the Container instance itself
	Copy() Container                // Copy() should return a copy of Container so it can be declared once per package
	Update(Kind, Resource) error    // Update() overrides underlying Kind Resource
	GetResource(Kind) Resource      // GetResource() returns underlying Resource for a Kind
	ForEachResource(func(Resource)) // ForEachResource() performs function on each Resource
	ForEachKind(func(Kind))         // ForEachKind() performs function on each Kind

	// caster methods to get underlying Resource instance for a Kind
	Namespace(Kind) *v1core.Namespace
	Deployment(Kind) *v1apps.Deployment
	Ingress(Kind) *v1beta1net.Ingress
	Secret(Kind) *v1core.Secret
	Service(Kind) *v1core.Service
	ConfigMap(Kind) *v1core.ConfigMap
	PersistentVolumeClaim(Kind) *v1core.PersistentVolumeClaim
}

type Controller interface {
	Container // Container of which Controller is in control

	Hooks() Hooks
	Configure(option Option) // Configure accepts Option to modify Controller
	ClientSet() ClientSet

	// todo should hooks run here?
	GetKind(Kind) (Resource, error)    // GetKind(Kind) performs kubernetes get request updating underlying Resource
	CreateKind(Kind) (Resource, error) // CreateKind(Kind) performs kubernetes create request for underlying Resource
	DeleteKind(Kind) error             // DeleteKind(Kind) performs kubernetes delete request for underlying Resource

	GetContainer() []error    // GetContainer() performs kubernetes get request for all Kind's in Container
	CreateContainer() []error // CreateContainer() performs kubernetes create request for all Kind's in Container
	DeleteContainer() []error // DeleteContainer() performs kubernetes delete request for all Kind's in Container
}

type Hook func(Container) error

type HookErr func(Container, Kind, error) error

type HookErrType string

type HookType string

type Hooks map[HookType][]Hook

type HooksErr map[HookErrType][]HookErr

type HooksManager interface {
	Hooks() Hooks
	Override(Hooks)
	Register(Hooks)
}

type Kind interface {
	Name() string
	Cast() Resource // Cast() should return new instance of Resource
	Delete(contr ClientSet, ctx context.Context, name string, opts v1meta.DeleteOptions) error
	Get(contr ClientSet, ctx context.Context, name string, opts v1meta.GetOptions) (Resource, error)
	Create(contr ClientSet, ctx context.Context, res Resource, opts v1meta.CreateOptions) (Resource, error)
}

type Option func(*BasicController)

type Resource interface {
	v1meta.Common
	v1meta.Object
	v1meta.ObjectMetaAccessor
	schema.ObjectKind
	fmt.Stringer
}