sync

Documentation

Index

• Variables
• func Init(ctx context.Context, artifacts []*latestV1.Artifact) error
• func Perform(ctx context.Context, image string, files syncMap, ...) error
• type Config
• type Item
  • func NewItem(ctx context.Context, a *latestV1.Artifact, e filemon.Events, ...) (*Item, error)
• type Syncer
  • func NewSyncer(cfg Config) Syncer

Variables

var (
	WorkingDir = docker.RetrieveWorkingDir
	Labels     = docker.RetrieveLabels
	SyncMap    = syncMapForArtifact
)

For testing

Functions

func Init

func Init(ctx context.Context, artifacts []*latestV1.Artifact) error

func Perform

func Perform(ctx context.Context, image string, files syncMap, cmdFn func(context.Context, v1.Pod, v1.Container, syncMap) *exec.Cmd, namespaces []string) error

Types

type Config

type Config interface {
	kubectl.Config

	GetNamespaces() []string
}

type Item

type Item struct {
	Image  string
	Copy   map[string][]string
	Delete map[string][]string
}

func NewItem

func NewItem(ctx context.Context, a *latestV1.Artifact, e filemon.Events, builds []graph.Artifact, cfg docker.Config, dependentArtifactsCount int) (*Item, error)

type Syncer

type Syncer interface {
	Sync(context.Context, *Item) error
}

func NewSyncer

func NewSyncer(cfg Config) Syncer