composer

Documentation

Index

• Variables
• type Composer
  • func New(mgr manager.Manager) Composer
• type General
  • func (g *General) CreateComposer(mgr manager.Manager) Composer
  • func (g *General) DesiredDeployment(s *suggestionsv1beta1.Suggestion) (*appsv1.Deployment, error)
  • func (g *General) DesiredRBAC(s *suggestionsv1beta1.Suggestion) (*corev1.ServiceAccount, *rbacv1.Role, *rbacv1.RoleBinding, error)
  • func (g *General) DesiredService(s *suggestionsv1beta1.Suggestion) (*corev1.Service, error)
  • func (g *General) DesiredVolume(s *suggestionsv1beta1.Suggestion) (*corev1.PersistentVolumeClaim, *corev1.PersistentVolume, error)

Variables

var (
	ComposerRegistry = make(map[string]Composer)
)

Types

type Composer

type Composer interface {
	DesiredDeployment(s *suggestionsv1beta1.Suggestion) (*appsv1.Deployment, error)
	DesiredService(s *suggestionsv1beta1.Suggestion) (*corev1.Service, error)
	DesiredVolume(s *suggestionsv1beta1.Suggestion) (*corev1.PersistentVolumeClaim, *corev1.PersistentVolume, error)
	DesiredRBAC(s *suggestionsv1beta1.Suggestion) (*corev1.ServiceAccount, *rbacv1.Role, *rbacv1.RoleBinding, error)
	CreateComposer(mgr manager.Manager) Composer
}

func New

func New(mgr manager.Manager) Composer

type General

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

func (*General) CreateComposer

func (g *General) CreateComposer(mgr manager.Manager) Composer

CreateComposer create instance of composer interface with given manager

func (*General) DesiredDeployment

func (g *General) DesiredDeployment(s *suggestionsv1beta1.Suggestion) (*appsv1.Deployment, error)

DesiredDeployment returns desired deployment for suggestion

func (*General) DesiredRBAC

func (g *General) DesiredRBAC(s *suggestionsv1beta1.Suggestion) (*corev1.ServiceAccount, *rbacv1.Role, *rbacv1.RoleBinding, error)

DesiredRBAC returns desired ServiceAccount, Role and RoleBinding for the Suggestion

func (*General) DesiredService

func (g *General) DesiredService(s *suggestionsv1beta1.Suggestion) (*corev1.Service, error)

DesiredService returns desired service for suggestion

func (*General) DesiredVolume

func (g *General) DesiredVolume(s *suggestionsv1beta1.Suggestion) (*corev1.PersistentVolumeClaim, *corev1.PersistentVolume, error)

DesiredVolume returns desired PVC and PV for Suggestion. If PV doesn't exist in Katib config return nil for PV.