service

Documentation

Index

• Constants
• type QueueWorker
• type Scheduler
  • func NewScheduler(worker QueueWorker, downloader eve.CloudDownloader, uploader eve.CloudUploader, ...) *Scheduler
  • func (s *Scheduler) Logger(ctx context.Context) *zap.Logger
  • func (s *Scheduler) Start()
  • func (s *Scheduler) Stop()
• type TemplateJobData
• type TemplateServiceData

Constants

const (
	CommandUpdateDeployment string = "api-update-deployment"
	CommandCallbackMessage  string = "api-callback-message"
)

const TimeoutExitCode = 124

Public CONST

Types

type QueueWorker

type QueueWorker interface {
	Start(queue.Handler)
	Stop()
	DeleteMessage(ctx context.Context, m *queue.M) error
	// Message sends a message to a different queue given a url, not this one
	Message(ctx context.Context, qUrl string, m *queue.M) error
}

type Scheduler

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

func NewScheduler

func NewScheduler(
	worker QueueWorker,
	downloader eve.CloudDownloader,
	uploader eve.CloudUploader,
	apiQUrl string,
	k8sDynamic dynamic.Interface,
	k8sClient *kubernetes.Clientset,
) *Scheduler

func (*Scheduler) Logger

func (s *Scheduler) Logger(ctx context.Context) *zap.Logger

func (*Scheduler) Start

func (s *Scheduler) Start()

func (*Scheduler) Stop

func (s *Scheduler) Stop()

type TemplateJobData

type TemplateJobData struct {
	Plan *eve.NSDeploymentPlan
	Job  *eve.DeployJob
}

type TemplateServiceData

type TemplateServiceData struct {
	Plan    *eve.NSDeploymentPlan
	Service *eve.DeployService
}