orchestrator

Documentation

Index

• Constants
• type Job
  • func (j *Job) Run()
• type Orchestrator
  • func NewOrchestrator(ctx context.Context, wg *sync.WaitGroup) *Orchestrator
  • func (o *Orchestrator) AadToAwsSyncStatusProgress() bool
  • func (o *Orchestrator) AwsToK8sSyncStatusProgress() bool
  • func (o *Orchestrator) CapSvcToAadSyncProgress() bool
  • func (o *Orchestrator) Init(conf config.Config)
• type SyncStatus
  • func (s *SyncStatus) InProgress() bool
  • func (s *SyncStatus) SetStatus(status bool)

Constants

const AwsMappingName = "awsMapping"

const AwsToKubernetesName = "awsToK8s"

const AzureAdToAwsName = "aadToAws"

const CapabilityServiceToAzureAdName = "capSvcToAad"

Types

type Job

type Job struct {
	Name   string
	Status *SyncStatus

	ScheduleEnabled bool
	// contains filtered or unexported fields
}

func (*Job) Run

func (j *Job) Run()

type Orchestrator

type Orchestrator struct {
	Jobs map[string]*Job
	// contains filtered or unexported fields
}

Orchestrator Used for managing long-lived fully fledged sync jobs

func NewOrchestrator

func NewOrchestrator(ctx context.Context, wg *sync.WaitGroup) *Orchestrator

func (*Orchestrator) AadToAwsSyncStatusProgress

func (o *Orchestrator) AadToAwsSyncStatusProgress() bool

func (*Orchestrator) AwsToK8sSyncStatusProgress

func (o *Orchestrator) AwsToK8sSyncStatusProgress() bool

func (*Orchestrator) CapSvcToAadSyncProgress

func (o *Orchestrator) CapSvcToAadSyncProgress() bool

func (*Orchestrator) Init

func (o *Orchestrator) Init(conf config.Config)

type SyncStatus

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

func (*SyncStatus) InProgress

func (s *SyncStatus) InProgress() bool

func (*SyncStatus) SetStatus

func (s *SyncStatus) SetStatus(status bool)