tracker

Documentation

Index

• type Config
• type DeployMessage
• type FailedPodLogData
• type FinishedStatusData
• type PodInfo
• type StatusData
• type Tracker
  • func NewTracker(k8sClient kubernetes.Interface, customIF informer.SharedInformerFactory, ...) (*Tracker, error)
  • func (t *Tracker) InformerQueueMerger()
  • func (t *Tracker) Run(threadCount int, stopCh <-chan struct{}, waitgroup *sync.WaitGroup) error

Types

type Config

type Config struct {
	Namespace            string
	SQSregion            string
	Endpointendpointtype string
	Cluster              string
	Version              string
	KubeDeployEndpoint   string
	RobbieEndpoint       string
	KCDapp               string
}

Config holds cracker configuration data

type DeployMessage

type DeployMessage struct {
	Type    string
	Version string
	Body    interface{}
	Retries int
}

DeployMessage hold a message information

type FailedPodLogData

type FailedPodLogData struct {
	Cluster   string
	Timestamp time.Time
	Deploy    appsv1.Deployment
	Version   string

	PodName           string
	ContainerName     string
	Logs              string
	PodFailureReason  string
	PodFailureMessage string
}

FailedPodLogData is FailedPodLogData

type FinishedStatusData

type FinishedStatusData struct {
	Cluster   string
	Timestamp time.Time
	Deploy    appsv1.Deployment
	Version   string
	Success   bool
}

FinishedStatusData format for complete job

type PodInfo

type PodInfo struct {
	Name            string
	Status          string
	HostIP          string
	PodIP           string
	ContainerImages []string
}

PodInfo holds information about a Pod

type StatusData

type StatusData struct {
	Cluster     string
	Timestamp   time.Time
	Deploy      appsv1.Deployment
	PodInfoList []PodInfo
	Version     string
}

StatusData format of data to send to kubedeploy

type Tracker

type Tracker struct {
	KubeDeployEndpointAPI string
	RobbieEndpointAPI     string
	// contains filtered or unexported fields
}

Tracker holds comonents needed to track a deployment

func NewTracker

func NewTracker(k8sClient kubernetes.Interface, customIF informer.SharedInformerFactory, k8sIF k8sinformers.SharedInformerFactory, c Config) (*Tracker, error)

NewTracker Creates a new tracker

func (*Tracker) InformerQueueMerger

func (t *Tracker) InformerQueueMerger()

InformerQueueMerger empties the informer queues into the main work queue

func (*Tracker) Run

func (t *Tracker) Run(threadCount int, stopCh <-chan struct{}, waitgroup *sync.WaitGroup) error

Run starts the tracker