control

Documentation

Index

• Constants
• type Control
  • func New(clients k8s.Client, o Options, ready func()) *Control
  • func (c *Control) Run(ctx context.Context) error
• type Inform
• type List
• type Options
• type Resources
  • func (r *Resources) Resolve(ctx context.Context, retry *k8s.Retry, defaultImage string, clients k8s.Client) error
• type Topology
  • func NewTopology(clients k8s.Client, vinceLister vince_listers.VinceLister, ...) *Topology
  • func (t *Topology) Build(ctx context.Context, filter *k8s.ResourceFilter, defaultImage string) error
• type VinceAPI

Constants

const (
	APP       = "app.kubernetes.io/name"
	COMPONENT = "app.kubernetes.io/component"
	VERSION   = "app.kubernetes.io/version"
	PART      = "app.kubernetes.io/part-of"
	MANAGED   = "app.kubernetes.io/managed-by"
)

Types

type Control

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

func New

func New(clients k8s.Client, o Options, ready func()) *Control

func (*Control) Run

func (c *Control) Run(ctx context.Context) error

type Inform

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

type List

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

type Options

type Options struct {
	MasterURL        string
	KubeConfig       string
	Port             int
	Image            string
	Namespace        string
	WatchNamespaces  []string
	IgnoreNamespaces []string
}

type Resources

type Resources struct {
	Secrets     map[string]*corev1.Secret
	Service     map[string]*corev1.Service
	StatefulSet map[string]*appsv1.StatefulSet
	Vinces      map[string]*v1alpha1.Vince
	Sites       map[string][]*v1alpha1.Site
}

func (*Resources) Resolve

func (r *Resources) Resolve(ctx context.Context, retry *k8s.Retry, defaultImage string, clients k8s.Client) error

type Topology

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

func NewTopology

func NewTopology(
	clients k8s.Client,
	vinceLister vince_listers.VinceLister,
	siteLister vince_listers.SiteLister,
	statefulSetLister app_listers.StatefulSetLister,
	serviceLister listers.ServiceLister,
	secretsLister listers.SecretLister,
) *Topology

func (*Topology) Build

func (t *Topology) Build(ctx context.Context, filter *k8s.ResourceFilter, defaultImage string) error

type VinceAPI

type VinceAPI interface {
	List(context.Context) ([]*v1.Site, error)
	Get(ctx context.Context, domain string) (*v1.Site, error)
	Create(ctx context.Context, domain string, public bool) (*v1.Site, error)
}