core

Documentation

Index

• Variables
• func Main(clientset kubernetes.Interface)
• type ConfigStore
  • func NewConfigStore() ConfigStore
• type Controller
  • func (c *Controller) Do()
• type Data
• type KubeRepo
  • func NewKubeRepo(clientset kubernetes.Interface, cache ConfigStore) KubeRepo

Variables

var (
	ErrNotFound = fmt.Errorf("not found")
)

Functions

func Main

func Main(clientset kubernetes.Interface)

Types

type ConfigStore

type ConfigStore interface {
	Set(ns, typ, name string, data Data) error
	Get(ns, typ, name string) (*Data, error)
}

func NewConfigStore

func NewConfigStore() ConfigStore

type Controller

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

func (*Controller) Do

func (c *Controller) Do()

type Data

type Data struct {
	Value string
	Time  time.Time
}

type KubeRepo

type KubeRepo interface {
	ListWatchedDeploys(ns string) ([]*appsv1.Deployment, error)
	GetConfigMapLatestUpdatedTime(name string, ns string) (time.Time, error)
	GetSecretLatestUpdatedTime(name string, ns string) (time.Time, error)
	RolloutRestartDeployment(name string, ns string) error
}

func NewKubeRepo

func NewKubeRepo(clientset kubernetes.Interface, cache ConfigStore) KubeRepo