checkpoint

Documentation

Index

• func DeleteSPD(cpm checkpointmanager.CheckpointManager, ...) error
• func LoadSPDs(cpm checkpointmanager.CheckpointManager, skipCorruptionError bool) ([]*v1alpha1.ServiceProfileDescriptor, error)
• func WriteSPD(cpm checkpointmanager.CheckpointManager, ...) error
• type Data
  • func (cp *Data) GetSPD() *v1alpha1.ServiceProfileDescriptor
  • func (cp *Data) MarshalCheckpoint() ([]byte, error)
  • func (cp *Data) UnmarshalCheckpoint(blob []byte) error
  • func (cp *Data) VerifyChecksum() error
• type ServiceProfileCheckpoint
  • func NewServiceProfileCheckpoint(spd *v1alpha1.ServiceProfileDescriptor) ServiceProfileCheckpoint

Functions

func DeleteSPD

func DeleteSPD(cpm checkpointmanager.CheckpointManager, spd *v1alpha1.ServiceProfileDescriptor) error

DeleteSPD deletes a checkpoint from disk if present

func LoadSPDs

func LoadSPDs(cpm checkpointmanager.CheckpointManager, skipCorruptionError bool) ([]*v1alpha1.ServiceProfileDescriptor, error)

LoadSPDs Loads All Checkpoints from disk

func WriteSPD

func WriteSPD(cpm checkpointmanager.CheckpointManager, spd *v1alpha1.ServiceProfileDescriptor) error

WriteSPD a checkpoint to a file on disk if annotation is present

Types

type Data

type Data struct {
	SPD      *v1alpha1.ServiceProfileDescriptor
	Checksum checksum.Checksum
}

Data to be stored as checkpoint

func (*Data) GetSPD

func (cp *Data) GetSPD() *v1alpha1.ServiceProfileDescriptor

GetSPD retrieves the spd from the checkpoint

func (*Data) MarshalCheckpoint

func (cp *Data) MarshalCheckpoint() ([]byte, error)

MarshalCheckpoint returns marshaled data

func (*Data) UnmarshalCheckpoint

func (cp *Data) UnmarshalCheckpoint(blob []byte) error

UnmarshalCheckpoint returns unmarshalled data

func (*Data) VerifyChecksum

func (cp *Data) VerifyChecksum() error

VerifyChecksum verifies that passed checksum is same as calculated checksum

type ServiceProfileCheckpoint

type ServiceProfileCheckpoint interface {
	checkpointmanager.Checkpoint
	GetSPD() *v1alpha1.ServiceProfileDescriptor
}

ServiceProfileCheckpoint defines the operations to retrieve spd

func NewServiceProfileCheckpoint

func NewServiceProfileCheckpoint(spd *v1alpha1.ServiceProfileDescriptor) ServiceProfileCheckpoint

NewServiceProfileCheckpoint returns new spd checkpoint