domain

type AppendChunkOptions struct {
	MinTailSlackLength int64
}

type ChooseVolumeOptions struct {
	MaxAttempts int
	Filter      func(id VolumeID) bool
	Probe       func(total, start, attempt int) int
}

type Chunk interface {
	ID() ChunkID
	WriterKey() []byte
	CreatedAt() time.Time
	ExpiresAt() (time.Time, bool)
	UpdatedAt() (time.Time, bool)
	Size() (int64, bool)
	Version() (uint64, bool)
	DeletedAt() (time.Time, bool)
	State() ChunkState
	// contains filtered or unexported methods
}

type ChunkHandle interface {
	io.Closer

	OpenReader(ctx context.Context) (ChunkReader, error)
	OpenRangeReader(ctx context.Context, offset, length int64) (ChunkRangeReader, error)
	OpenReaderAt(ctx context.Context) (ChunkReaderAt, error)
}

type ChunkID [16]byte

type ChunkIDGenerator interface {
	Generate(volume VolumeID) (ChunkID, error)
}

type ChunkRangeReader interface {
	io.Closer
	io.Reader
}

type ChunkReader interface {
	io.Closer
	io.Reader
}

type ChunkReaderAt interface {
	io.Closer
	io.ReaderAt
}

type ChunkRepository interface {
	Get(ctx context.Context, id ChunkID) (Chunk, error)
	GetWithWriterKey(ctx context.Context, writerKey []byte) (Chunk, error)
	Upsert(ctx context.Context, chunk Chunk) error
	Delete(ctx context.Context, id ChunkID) error
}

type ChunkState int

type ChunkStorage interface {
	Open(ctx context.Context, id ChunkID) (ChunkHandle, error)
	Create(ctx context.Context, id ChunkID, opts CreateChunkOptions) error
	Put(ctx context.Context, id ChunkID, r io.Reader, n int64, opts PutChunkOptions) error
	Append(ctx context.Context, id ChunkID, knownSize int64, r io.Reader, n int64, opts AppendChunkOptions) error
	Delete(ctx context.Context, id ChunkID) error
	ShrinkToFit(ctx context.Context, id ChunkID, knownSize int64, opts ShrinkChunkToFitOptions) error
	Exists(ctx context.Context, id ChunkID) (bool, error)
}

type CreateChunkOptions struct {
	MinTailSlackLength int64
}

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

type FileStoreFormat interface {
	Initialize(node NodeID, volume VolumeID, path string) error
	Stat(path string) (*VolumeInfo, error)
	Open(path string) (VolumeHandle, error)
}

type FilesystemType string

type IOKitIOBlockStorageDriverStatistics struct {
	// Describes the number of bytes read since the block storage driver was instantiated.
	//
	// This property describes the number of bytes read since the block storage driver was instantiated.
	// It is one of the statistic entries listed under the top-level kIOBlockStorageDriverStatisticsKey property table.
	// It has an OSNumber value.
	BytesRead int64 `plist:"Bytes (Read)"`
	// Describes the number of bytes written since the block storage driver was instantiated.
	//
	// This property describes the number of bytes written since the block storage driver was instantiated.
	// It is one of the statistic entries listed under the top-level kIOBlockStorageDriverStatisticsKey property table.
	// It has an OSNumber value.
	BytesWritten int64 `plist:"Bytes (Write)"`
	// Describes the number of nanoseconds of latency during reads since the block storage driver was instantiated.
	//
	// This property describes the number of nanoseconds of latency during reads since the block storage driver was instantiated.
	// It is one of the statistic entries listed under the top-level kIOBlockStorageDriverStatisticsKey property table.
	// It has an OSNumber value.
	LatentReadTime int64 `plist:"Latency Time (Read)"`
	// Describes the number of nanoseconds of latency during writes since the block storage driver was instantiated.
	//
	// This property describes the number of nanoseconds of latency during writes since the block storage driver was instantiated.
	// It is one of the statistic entries listed under the top-level kIOBlockStorageDriverStatisticsKey property table.
	// It has an OSNumber value.
	LatentWriteTime int64 `plist:"Latency Time (Write)"`
	// Describes the number of read errors encountered since the block storage driver was instantiated.
	//
	// This property describes the number of read errors encountered since the block storage driver was instantiated.
	// It is one of the statistic entries listed under the top-level kIOBlockStorageDriverStatisticsKey property table.
	// It has an OSNumber value.
	ReadErrors int64 `plist:"Errors (Read)"`
	// Describes the number of read retries required since the block storage driver was instantiated.
	//
	// This property describes the number of read retries required since the block storage driver was instantiated.
	// It is one of the statistic entries listed under the top-level kIOBlockStorageDriverStatisticsKey property table.
	// It has an OSNumber value.
	ReadRetries int64 `plist:"Retries (Read)"`
	// Describes the number of read operations processed since the block storage driver was instantiated.
	//
	// This property describes the number of read operations processed since the block storage driver was instantiated.
	// It is one of the statistic entries listed under the top-level kIOBlockStorageDriverStatisticsKey property table.
	// It has an OSNumber value.
	Reads int64 `plist:"Operations (Read)"`
	// Describes the number of nanoseconds spent performing reads since the block storage driver was instantiated.
	//
	// This property describes the number of nanoseconds spent performing reads since the block storage driver was instantiated. It is one of the statistic entries listed under the top-level kIOBlockStorageDriverStatisticsKey property table. It has an OSNumber value.
	TotalReadTime int64 `plist:"Total Time (Read)"`
	// Describes the number of nanoseconds spent performing writes since the block storage driver was instantiated.
	//
	// This property describes the number of nanoseconds spent performing writes since the block storage driver was instantiated.
	// It is one of the statistic entries listed under the top-level kIOBlockStorageDriverStatisticsKey property table.
	// It has an OSNumber value.
	TotalWriteTime int64 `plist:"Total Time (Write)"`
	// Describes the number of write errors encountered since the block storage driver was instantiated.
	//
	// This property describes the number of write errors encountered since the block storage driver was instantiated.
	// It is one of the statistic entries listed under the top-level kIOBlockStorageDriverStatisticsKey property table.
	// It has an OSNumber value.
	WriteErrors int64 `plist:"Errors (Write)"`
	// Describes the number of write retries required since the block storage driver was instantiated.
	//
	// This property describes the number of write retries required since the block storage driver was instantiated.
	// It is one of the statistic entries listed under the top-level kIOBlockStorageDriverStatisticsKey property table.
	// It has an OSNumber value.
	WriteRetries int64 `plist:"Retries (Write)"`
	// Describes the number of write operations processed since the block storage driver was instantiated.
	//
	// This property describes the number of write operations processed since the block storage driver was instantiated.
	// It is one of the statistic entries listed under the top-level kIOBlockStorageDriverStatisticsKey property table.
	// It has an OSNumber value.
	Writes int64 `plist:"Operations (Write)"`
}

type InterconnectType string

type LinuxBlockLayerStatistics struct {
	// Reads is the number of read operations completed.
	Reads int64
	// MergedReads is the number of read operations merged.
	MergedReads int64
	// SectorsRead is the number of sectors read.
	SectorsRead int64
	// ReadTicks is the total number of milliseconds that read I/O requests have waited on this block device.
	// If multiple requests are waiting, this value increases faster than real time.
	ReadTicks int64
	// Writes is the number of write operations completed.
	Writes int64
	// MergedWrites is the number of write operations merged.
	MergedWrites int64
	// SectorsWritten is the number of sectors written.
	SectorsWritten int64
	// WriteTicks is the total number of milliseconds that write I/O requests have waited on this block device.
	// If multiple requests are waiting, this value increases faster than real time.
	WriteTicks int64
	// InFlight is the number of I/O operations currently in progress.
	InFlight int64
	// IOTicks is the total number of milliseconds during which the device has had I/O requests queued.
	IOTicks int64
	// TimeInQueue is the total wait time for all I/O requests, in milliseconds.
	TimeInQueue int64
	// Discards is the number of discard operations completed.
	Discards int64
	// MergedDiscards is the number of discard operations merged.
	MergedDiscards int64
	// SectorsDiscarded is the number of sectors discarded.
	SectorsDiscarded int64
	// DiscardTicks is the total number of milliseconds that discard I/O requests have waited on this block device.
	// If multiple requests are waiting, this value increases faster than real time.
	DiscardTicks int64
	// Flushes is the number of flush operations completed.
	Flushes int64
	// FlushTicks is the total number of milliseconds that flush I/O requests have waited on this block device.
	// If multiple requests are waiting, this value increases faster than real time.
	FlushTicks int64
}

type MediumType string

type NodeClaim struct {
	ID    NodeID
	Proof [32]byte
}

type NodeClaimRegistry interface {
	Register(ctx context.Context, claim *NodeClaim) error
	Check(ctx context.Context, claim *NodeClaim) error
}

type NodeClaimRepository interface {
	Get(ctx context.Context) (*NodeClaim, error)
	Upsert(ctx context.Context, claim *NodeClaim) error
}

type NodeID uint32

type NodeIDProvider interface {
	GetNodeID() NodeID
}

type NodeLabelPublisher interface {
	Publish(node NodeID, labels map[string]string)
}

type NodeLabelSource interface {
	Read() map[string]string
	Watch(watchCtx context.Context) <-chan struct{}
}

type NodePeer struct {
	ID   NodeID
	GRPC NodePeerGRPC
}

type NodePeerGRPC struct {
	URLs []string
}

type NodePeerResolver interface {
	Resolve(ctx context.Context, nodeID NodeID) (*NodePeer, error)
	Watch(ctx context.Context, nodeID NodeID) (<-chan struct{}, error)
}

type NodePresence struct {
	ID    NodeID
	Nonce [32]byte
	GRPC  NodePresenceGRPC
}

type NodePresenceGRPC struct {
	URLs []string
}

type NodePresencePublisher interface {
	Publish(presence *NodePresence)
}

type NodeSeed []byte

type NodeSeedGenerator interface {
	Generate() (NodeSeed, error)
}

type NodeSeedRepository interface {
	Get(ctx context.Context) (NodeSeed, error)
	Upsert(ctx context.Context, seed NodeSeed) error
}

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

type ProtocolType string

type PutChunkOptions struct {
	MinTailSlackLength int64
}

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

type Sample[T any] struct {
	// The sampled value
	Value T
	// A monotonic increasing epoch counter incremented whenever the underlying provider attempts to update stats.
	Epoch uint64
	// The time at which the sample was taken.
	Time time.Time
	// Any error encountered while obtaining the sample.
	Error error
}

type ShrinkChunkToFitOptions struct {
	MaxTailSlackLength int64
}

type SpaceUtilizationStatistics struct {
	// TotalBytes is the total space of the volume in bytes.
	TotalBytes int64
	// UsedBytes is the used space of the volume in bytes.
	UsedBytes int64
	// FreeBytes is the free space of the volume in bytes.
	FreeBytes int64
}

type VolumeCharacteristics struct {
	DeviceName   string
	Medium       MediumType
	Interconnect InterconnectType
	Protocol     ProtocolType
	Vendor       string
	Model        string
	SerialNumber string

	Filesystem FilesystemType
	Zoning     ZoningType
}

type VolumeCharacteristicsProvider interface {
	Get() *VolumeCharacteristics
	Watch(watchCtx context.Context) <-chan struct{}
}

type VolumeChooser interface {
	Choose(options ChooseVolumeOptions) (VolumeID, error)
	Reset(ids []VolumeID)
	Refresh(id VolumeID)
}

type VolumeHandle interface {
	io.Closer

	Info() VolumeInfo

	GetChunkStorage() ChunkStorage

	GetCharacteristicsProvider() VolumeCharacteristicsProvider

	GetLabelSources() []VolumeLabelSource

	GetStatusProvider() VolumeStatusProvider

	GetStructuredLoggingFieldsProvider() VolumeStructuredLoggingFieldsProvider

	GetOTelAttributeProvider() VolumeOTelAttributeProvider

	GetIOKitIOBlockStorageDriverStatisticsProvider() VolumeStatisticsProvider[IOKitIOBlockStorageDriverStatistics]

	GetLinuxBlockLayerStatisticsProvider() VolumeStatisticsProvider[LinuxBlockLayerStatistics]

	GetSpaceUtilizationStatisticsProvider() VolumeStatisticsProvider[SpaceUtilizationStatistics]
}

type VolumeHealth int

type VolumeID uint16

type VolumeIDCounter interface {
	Next() (VolumeID, error)
}

type VolumeInfo struct {
	ID   VolumeID
	Node NodeID
}

type VolumeLabelPublisher interface {
	Publish(node NodeID, labels map[VolumeID]map[string]string)
}

type VolumeLabelSource interface {
	Read() map[string]string
	Watch(watchCtx context.Context) <-chan struct{}
}

type VolumeOTelAttributeProvider interface {
	Get() []attribute.KeyValue
}

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

type VolumeStatisticsProvider[T any] interface {
	Get() Sample[T]
	Watch(watchCtx context.Context) <-chan struct{}
}

type VolumeStatus struct {
	Health VolumeHealth
}

type VolumeStatusProvider interface {
	Get() VolumeStatus
}

type VolumeStructuredLoggingFieldsProvider interface {
	Get() []any
}

type ZoningType string