fsm

type FSM interface {
	ID() string
	Run()
	GetStatus() string
	GetCurrentState() string
	Mounted() bool

	Mount() (response *types.Event)
	Unmount() (response *types.Event)

	// TODO: review the call, maybe it's possible to internalize behaviour
	PushCompleted(success bool)
	// TODO: review the call, maybe it's possible to internalize behaviour
	PublishNewSnaps(server string, payload interface{}) error
	// TODO: review the call, maybe it's possible to internalize behaviour
	TransitionSubscribe(channel string, ch chan interface{})
	TransitionUnsubscribe(channel string, ch chan interface{})

	// metadata API
	GetMetadata(nodeID string) map[string]string
	ListMetadata() map[string]map[string]string
	SetMetadata(nodeID string, meta map[string]string)
	GetSnapshots(nodeID string) []*types.Snapshot
	ListSnapshots() map[string][]*types.Snapshot
	SetSnapshots(nodeID string, snapshots []*types.Snapshot)

	// Local snapshots from ZFS
	ListLocalSnapshots() []*types.Snapshot

	Submit(event *types.Event, requestID string) (reply chan *types.Event, err error)

	// WriteFile - reads the supplied Contents io.Reader and writes into the volume,
	// response will be sent to a provided Response channel
	WriteFile(source *types.InputFile)

	// ReadFile - reads a file from the volume into the supplied Contents io.Writer,
	// response will be sent to a provided Response channel
	ReadFile(destination *types.OutputFile)

	// StatFile - reads type and size of a file,
	// response will be sent to a provided Response channel
	StatFile(destination *types.OutputFile)

	// DumpState is used for diagnostics
	DumpState() *FSMStateDump
}

type FSMStateDump struct {
	Filesystem              *types.Filesystem
	Status                  string
	CurrentState            string
	LastTransitionTimestamp int64

	LastTransferRequest   types.TransferRequest
	LastTransferRequestID string

	HandoffRequest *types.Event

	DirtyDelta int64
	SizeBytes  int64
}

type FsConfig struct {
	Config config.Config

	FilesystemID    string
	StateManager    StateManager
	Registry        registry.Registry
	UserManager     user.UserManager
	RegistryStore   store.RegistryStore
	FilesystemStore store.FilesystemStore
	ServerStore     store.ServerStore

	ContainerClient      container.Client
	LocalReceiveProgress observer.Observer
	NewSnapsOnMaster     observer.Observer
	DeathObserver        observer.Observer

	FilesystemMetadataTimeout int64

	// zfs executable path
	ZFSPath string
	// zpool executable path
	ZPoolPath string
	// Previously known as main.MOUNT_ZFS
	MountZFS string

	// PoolName is a required
	PoolName string
}

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

type NoCommonSnapshots struct {
	FromSnaps []*types.Snapshot
	ToSnaps   []*types.Snapshot
}

type NoFromSnaps struct{}

type StateFn func(*FsMachine) StateFn

type StateManager interface {
	InitFilesystemMachine(filesystemId string) (FSM, error)
	GetFilesystemMachine(filesystemId string) (FSM, error)

	// ActivateFilesystem(filesystemId string) error
	AlignMountStateWithMasters(filesystemId string) error
	ActivateClone(topLevelFilesystemId, originFilesystemId, originSnapshotId, newCloneFilesystemId, newBranchName string) (string, error)
	DeleteFilesystem(filesystemId string) error
	DeleteFilesystemFromMap(filesystemId string)
	// current node ID
	NodeID() string

	UpdateSnapshotsFromKnownState(server, filesystem string, snapshots []*types.Snapshot) error
	SnapshotsFor(server string, filesystemId string) ([]types.Snapshot, error)
	SnapshotsForCurrentMaster(filesystemId string) ([]types.Snapshot, error)

	AddressesForServer(server string) []string

	RegisterNewFork(originFilesystemId, originSnapshotId, forkNamespace, forkName, forkFilesystemId string) error

	UpdateInterclusterTransfer(transferRequestId string, pollResult types.TransferPollResult)

	// TODO: move under a separate interface for Etcd related things
	MarkFilesystemAsLiveInEtcd(topLevelFilesystemId string) error
}

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

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

type ToSnapsUpToDate struct{}