statesync

Documentation

Index

• type Collection
• type StateSyncUnit
  • func NewStateSyncUnit() (*StateSyncUnit, error)
  • func (d *StateSyncUnit) RegisterIfritClient(c *ifrit.Client)
  • func (d *StateSyncUnit) SyncState() string
  • func (d *StateSyncUnit) SynchronizeDatasets(ctx context.Context, datasets map[string]*pb.Dataset, targetAddr string) (map[string]*pb.Dataset, error)

Types

type Collection

type Collection int

const (
	Datasets Collection = iota
	CheckoutDatasetPolicies
)

type StateSyncUnit

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

Describes the synchronization of the types defined in this package. It uses protobuf types and syncs

func NewStateSyncUnit

func NewStateSyncUnit() (*StateSyncUnit, error)

func (*StateSyncUnit) RegisterIfritClient

func (d *StateSyncUnit) RegisterIfritClient(c *ifrit.Client)

func (*StateSyncUnit) SyncState

func (d *StateSyncUnit) SyncState() string

func (*StateSyncUnit) SynchronizeDatasets

func (d *StateSyncUnit) SynchronizeDatasets(ctx context.Context, datasets map[string]*pb.Dataset, targetAddr string) (map[string]*pb.Dataset, error)