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) UpdateContainer(ctx context.Context, cInfo store.ContainerInfo, archiveToCopy io.Reader, ...) error
• type SyncletManager
  • func NewSyncletManager(kCli k8s.Client) SyncletManager
  • func NewSyncletManagerForTests(kCli k8s.Client, fakeCli synclet.SyncletClient) 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 {
	UpdateErr error

	Calls []UpdateContainerCall
}

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, fakeCli synclet.SyncletClient) 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
}