containerupdate

Documentation

Index

• type ContainerUpdater
• type DockerContainerUpdater
  • func NewDockerContainerUpdater(dCli docker.Client) *DockerContainerUpdater
  • func (cu *DockerContainerUpdater) UpdateContainer(ctx context.Context, cInfo store.ContainerInfo, archiveToCopy io.Reader, ...) error
• type ExecUpdater
  • func NewExecUpdater(kCli k8s.Client) *ExecUpdater
  • func (cu *ExecUpdater) UpdateContainer(ctx context.Context, cInfo store.ContainerInfo, archiveToCopy io.Reader, ...) error
• type FakeContainerUpdater
  • func (cu *FakeContainerUpdater) SetUpdateErr(err error)
  • func (cu *FakeContainerUpdater) UpdateContainer(ctx context.Context, cInfo store.ContainerInfo, archiveToCopy io.Reader, ...) error
• type SyncletManager
  • func NewSyncletManager(kCli k8s.Client) SyncletManager
  • func NewSyncletManagerForTests(kCli k8s.Client, sCli synclet.SyncletClient, fake *synclet.TestSyncletClient) SyncletManager
  • func (sm SyncletManager) ClientForPod(ctx context.Context, podID k8s.PodID, ns k8s.Namespace) (synclet.SyncletClient, error)
  • func (sm SyncletManager) OnChange(ctx context.Context, store store.RStore)
• type SyncletUpdater
  • func NewSyncletUpdater(sm SyncletManager) *SyncletUpdater
  • func (cu *SyncletUpdater) UpdateContainer(ctx context.Context, cInfo store.ContainerInfo, archiveToCopy io.Reader, ...) error
• type UpdateContainerCall

Types

type ContainerUpdater

type ContainerUpdater interface {
	UpdateContainer(ctx context.Context, cInfo store.ContainerInfo,
		archiveToCopy io.Reader, filesToDelete []string, cmds []model.Cmd, hotReload bool) error
}

type DockerContainerUpdater

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

func NewDockerContainerUpdater

func NewDockerContainerUpdater(dCli docker.Client) *DockerContainerUpdater

func (*DockerContainerUpdater) UpdateContainer

func (cu *DockerContainerUpdater) UpdateContainer(ctx context.Context, cInfo store.ContainerInfo,
	archiveToCopy io.Reader, filesToDelete []string, cmds []model.Cmd, hotReload bool) error

type ExecUpdater

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

func NewExecUpdater

func NewExecUpdater(kCli k8s.Client) *ExecUpdater

func (*ExecUpdater) UpdateContainer

func (cu *ExecUpdater) UpdateContainer(ctx context.Context, cInfo store.ContainerInfo,
	archiveToCopy io.Reader, filesToDelete []string, cmds []model.Cmd, hotReload bool) error

type FakeContainerUpdater

type FakeContainerUpdater struct {
	UpdateErrs []error

	Calls []UpdateContainerCall
}

func (*FakeContainerUpdater) SetUpdateErr

func (cu *FakeContainerUpdater) SetUpdateErr(err error)

func (*FakeContainerUpdater) UpdateContainer

func (cu *FakeContainerUpdater) UpdateContainer(ctx context.Context, cInfo store.ContainerInfo,
	archiveToCopy io.Reader, filesToDelete []string, cmds []model.Cmd, hotReload bool) error

type SyncletManager

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

func NewSyncletManager

func NewSyncletManager(kCli k8s.Client) SyncletManager

func NewSyncletManagerForTests

func NewSyncletManagerForTests(kCli k8s.Client, sCli synclet.SyncletClient, fake *synclet.TestSyncletClient) SyncletManager

func (SyncletManager) ClientForPod

func (sm SyncletManager) ClientForPod(ctx context.Context, podID k8s.PodID, ns k8s.Namespace) (synclet.SyncletClient, error)

func (SyncletManager) OnChange

func (sm SyncletManager) OnChange(ctx context.Context, store store.RStore)

type SyncletUpdater

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

func NewSyncletUpdater

func NewSyncletUpdater(sm SyncletManager) *SyncletUpdater

func (*SyncletUpdater) UpdateContainer

func (cu *SyncletUpdater) UpdateContainer(ctx context.Context, cInfo store.ContainerInfo,
	archiveToCopy io.Reader, filesToDelete []string, cmds []model.Cmd, hotReload bool) error

type UpdateContainerCall

type UpdateContainerCall struct {
	ContainerInfo store.ContainerInfo
	Archive       io.Reader
	ToDelete      []string
	Cmds          []model.Cmd
	HotReload     bool
}