sync

Documentation

Index

• func StoreAppMeta(ctx context.Context, app *model.DataStoreApp, ds datastore.DataStore) error
• func StoreApplicationRevision(ctx context.Context, dsApp *model.DataStoreApp, ds datastore.DataStore) error
• func StoreComponents(ctx context.Context, appPrimaryKey string, ...) error
• func StoreEnv(ctx context.Context, app *model.DataStoreApp, ds datastore.DataStore, ...) error
• func StoreEnvBinding(ctx context.Context, eb *model.EnvBinding, ds datastore.DataStore) error
• func StorePolicy(ctx context.Context, appPrimaryKey string, ...) error
• func StoreProject(ctx context.Context, name string, ds datastore.DataStore, ...) error
• func StoreTargets(ctx context.Context, dsApp *model.DataStoreApp, ds datastore.DataStore, ...) error
• func StoreWorkflow(ctx context.Context, dsApp *model.DataStoreApp, ds datastore.DataStore) error
• func StoreWorkflowRecord(ctx context.Context, dsApp *model.DataStoreApp, ds datastore.DataStore) error
• type ApplicationSync
  • func (a *ApplicationSync) Start(ctx context.Context, errorChan chan error)
• type CR2UX
  • func (c *CR2UX) AddOrUpdate(ctx context.Context, targetApp *v1beta1.Application) error
  • func (c *CR2UX) ConvertApp2DatastoreApp(ctx context.Context, targetApp *v1beta1.Application) (*model.DataStoreApp, error)
  • func (c *CR2UX) DeleteApp(ctx context.Context, targetApp *v1beta1.Application) error
• type WorkflowRecordSync
  • func (w *WorkflowRecordSync) Start(ctx context.Context, errorChan chan error)

Functions

func StoreAppMeta

func StoreAppMeta(ctx context.Context, app *model.DataStoreApp, ds datastore.DataStore) error

StoreAppMeta will sync application metadata from CR to datastore

func StoreApplicationRevision

func StoreApplicationRevision(ctx context.Context, dsApp *model.DataStoreApp, ds datastore.DataStore) error

StoreApplicationRevision will sync the application revision to datastore.

func StoreComponents

func StoreComponents(ctx context.Context, appPrimaryKey string, expComps []*model.ApplicationComponent, ds datastore.DataStore) error

StoreComponents will sync application components from CR to datastore

func StoreEnv

func StoreEnv(ctx context.Context, app *model.DataStoreApp, ds datastore.DataStore, envService service.EnvService) error

StoreEnv will sync application namespace from CR to datastore env, one namespace belongs to one env

func StoreEnvBinding

func StoreEnvBinding(ctx context.Context, eb *model.EnvBinding, ds datastore.DataStore) error

StoreEnvBinding will add envbinding for application CR one application one envbinding

func StorePolicy

func StorePolicy(ctx context.Context, appPrimaryKey string, expPolicies []*model.ApplicationPolicy, ds datastore.DataStore) error

StorePolicy will add/update/delete policies, we don't delete ref policy

func StoreProject

func StoreProject(ctx context.Context, name string, ds datastore.DataStore, projectService service.ProjectService) error

StoreProject will create project for synced application

func StoreTargets

func StoreTargets(ctx context.Context, dsApp *model.DataStoreApp, ds datastore.DataStore, targetService service.TargetService) error

StoreTargets will sync targets from application CR to datastore

func StoreWorkflow

func StoreWorkflow(ctx context.Context, dsApp *model.DataStoreApp, ds datastore.DataStore) error

StoreWorkflow will sync workflow application CR to datastore, it updates the only one workflow from the application with specified name

func StoreWorkflowRecord

func StoreWorkflowRecord(ctx context.Context, dsApp *model.DataStoreApp, ds datastore.DataStore) error

StoreWorkflowRecord will sync workflow status to datastore.

Types

type ApplicationSync

type ApplicationSync struct {
	KubeClient         client.Client              `inject:"kubeClient"`
	KubeConfig         *rest.Config               `inject:"kubeConfig"`
	Store              datastore.DataStore        `inject:"datastore"`
	ProjectService     service.ProjectService     `inject:""`
	ApplicationService service.ApplicationService `inject:""`
	TargetService      service.TargetService      `inject:""`
	EnvService         service.EnvService         `inject:""`
	Queue              workqueue.RateLimitingInterface
}

ApplicationSync sync application from cluster to database

func (*ApplicationSync) Start

func (a *ApplicationSync) Start(ctx context.Context, errorChan chan error)

Start prepares watchers and run their controllers, then waits for process termination signals

type CR2UX

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

CR2UX provides the Add/Update/Delete method

func (*CR2UX) AddOrUpdate

func (c *CR2UX) AddOrUpdate(ctx context.Context, targetApp *v1beta1.Application) error

AddOrUpdate will sync application CR to storage of VelaUX automatically

func (*CR2UX) ConvertApp2DatastoreApp

func (c *CR2UX) ConvertApp2DatastoreApp(ctx context.Context, targetApp *v1beta1.Application) (*model.DataStoreApp, error)

ConvertApp2DatastoreApp will convert Application CR to datastore application related resources

func (*CR2UX) DeleteApp

func (c *CR2UX) DeleteApp(ctx context.Context, targetApp *v1beta1.Application) error

DeleteApp will delete the application as the CR was deleted

type WorkflowRecordSync

type WorkflowRecordSync struct {
	Duration        time.Duration
	WorkflowService service.WorkflowService `inject:""`
}

WorkflowRecordSync sync workflow record from cluster to database

func (*WorkflowRecordSync) Start

func (w *WorkflowRecordSync) Start(ctx context.Context, errorChan chan error)

Start sync workflow record data