state

Documentation

Index

• func CleanupState(ctx context.Context, log logging.Logger, kubeClient client.Client, ...) error
• func StateSecretListOptions(namespace string, deployItem lsv1alpha1.ObjectReference) []client.ListOption
• type State
  • func New(kubeClient client.Client, namespace string, ...) *State
  • func (s *State) Backup(ctx context.Context) error
  • func (s *State) Restore(ctx context.Context) error
  • func (s *State) WithFs(fs vfs.FileSystem) *State

Functions

func CleanupState

func CleanupState(ctx context.Context, log logging.Logger, kubeClient client.Client, namespace string, deployItem lsv1alpha1.ObjectReference) error

CleanupState deletes all state secrets for a deployitem

func StateSecretListOptions

func StateSecretListOptions(namespace string, deployItem lsv1alpha1.ObjectReference) []client.ListOption

StateSecretListOptions returns the list options for all state secrets of a deploy item

Types

type State

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

State handles the backup and restore of state of container deploy item.

func New

func New(kubeClient client.Client, namespace string, deployItemKey lsv1alpha1.ObjectReference, statePath string) *State

New creates a new state instance.

func (*State) Backup

func (s *State) Backup(ctx context.Context) error

Backup tars the content of the State directory and stores it in a secrets in the cluster.

func (*State) Restore

func (s *State) Restore(ctx context.Context) error

Restore restores the latest state from the k8s cluster to the configured state path.

func (*State) WithFs

func (s *State) WithFs(fs vfs.FileSystem) *State

WithFs sets the fs for the state