agent

Documentation

Index

• Constants
• type Controller
  • func DeploymentController(kubeEnv *KubeEnv, gimletHost string, agentKey string) *Controller
  • func IngressController(kubeEnv *KubeEnv, gimletHost string, agentKey string) *Controller
  • func NewController(name string, listWatcher cache.ListerWatcher, objType rntme.Object, ...) *Controller
  • func PodController(kubeEnv *KubeEnv, gimletHost string, agentKey string) *Controller
  • func (c *Controller) Run(threadiness int, stopCh chan struct{})
• type Event
• type KubeEnv
  • func (e *KubeEnv) Services(repo string) ([]*api.Stack, error)

Constants

const AnnotationGitRepository = "gimlet.io/git-repository"

const AnnotationGitSha = "gimlet.io/git-sha"

const EventDeploymentCreated = "deploymentCreated"

const EventDeploymentDeleted = "deploymentDeleted"

const EventDeploymentUpdated = "deploymentUpdated"

const EventIngressCreated = "ingressCreated"

const EventIngressDeleted = "ingressDeleted"

const EventIngressUpdated = "ingressUpdated"

const EventPodCreated = "podCreated"

const EventPodDeleted = "podDeleted"

const EventPodUpdated = "podUpdated"

Types

type Controller

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

Controller demonstrates how to implement a controller with client-go.

func DeploymentController

func DeploymentController(kubeEnv *KubeEnv, gimletHost string, agentKey string) *Controller

func IngressController

func IngressController(kubeEnv *KubeEnv, gimletHost string, agentKey string) *Controller

func NewController

func NewController(
	name string,
	listWatcher cache.ListerWatcher,
	objType rntme.Object,
	eventHandler func(informerEvent Event, objectMeta meta_v1.ObjectMeta, obj interface{}) error,
) *Controller

NewController creates a new Controller.

func PodController

func PodController(kubeEnv *KubeEnv, gimletHost string, agentKey string) *Controller

func (*Controller) Run

func (c *Controller) Run(threadiness int, stopCh chan struct{})

Run begins watching and syncing.

type Event

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

Event indicate the informerEvent

type KubeEnv

type KubeEnv struct {
	Name      string
	Namespace string
	Client    kubernetes.Interface
}

func (*KubeEnv) Services

func (e *KubeEnv) Services(repo string) ([]*api.Stack, error)