ksync

Documentation

Index

• func Synchronized(store layerfs.Store, client client.Client, nodeName string) layerfs.Store
• type Updater
  • func (u *Updater) PrepareCommit(ctx context.Context, cacheName types.NamespacedName, ...) (commit bool, err error)
  • func (u *Updater) RegisterCacheVolume(ctx context.Context, cacheName types.NamespacedName, ...) (image string, err error)
  • func (u *Updater) UnregisterCacheVolume(ctx context.Context, cacheName types.NamespacedName, ...) error

Functions

func Synchronized

func Synchronized(store layerfs.Store, client client.Client, nodeName string) layerfs.Store

Types

type Updater

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

func (*Updater) PrepareCommit

func (u *Updater) PrepareCommit(ctx context.Context, cacheName types.NamespacedName, nodeName, volumeName string) (commit bool, err error)

func (*Updater) RegisterCacheVolume

func (u *Updater) RegisterCacheVolume(ctx context.Context, cacheName types.NamespacedName, nodeName, volumeName, defaultImage string, commit bool) (image string, err error)

func (*Updater) UnregisterCacheVolume

func (u *Updater) UnregisterCacheVolume(ctx context.Context, cacheName types.NamespacedName, nodeName, volumeName string, commitErr error) error