treeply

type BlockCompletion struct {
	Block    INodeBlock
	Filename string
}

type BlockError struct {
	Block INodeBlock
	Error error
}

type BlockID uint64

type BlockRequest struct {
	Block     INodeBlock
	BlockSize int64
	GetReader func(context.Context) (io.Reader, error)
	WorkDir   string
	Response  chan error
}

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

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

type BlocksDiagnostics struct {
	BlocksInUse  int
	FreeBlockIDs int
	Dir          string
}

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

type CloseReq struct {
	FD int
}

type CloseResp struct {
}

type Command struct {
	Type           string
	ReqConstructor func() interface{}
	Invoke         func(interface{}) (interface{}, error)
}

type DiagReq struct {
}

type DiagnosticRequest struct {
	Response chan *TransferServiceStatus
}

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

type DirEntry struct {
	Name  string
	INode INode
}

type DirRemoteProvider struct {
	Root            string
	DirListingDelay time.Duration
	ReadDelay       time.Duration
}

type DirRemoteProviderDiagnostics struct {
	Root string
}

type ErrorResp struct {
	Message string
}

type ExtendedDirEntry struct {
	Name  string
	INode INode
	Size  int64
	IsDir bool
}

type FileClient struct {
	FileService *FileService

	FileHandles map[int]*FileHandle
	// contains filtered or unexported fields
}

type FileClientDiagnostics struct {
	FileService     *FileServiceDiagnostics
	OpenFiles       int
	FreeFileHandles int
}

type FileClientDirEntry struct {
	Name  string
	Size  int64
	INode INode
	IsDir bool
}

type FileHandle struct {
	INode  INode
	Offset int64
}

type FileService struct {
	Remote               RemoteProvider
	INodes               *INodes
	Root                 INode
	TransferServiceQueue chan interface{}
}

type FileServiceDiagnostics struct {
	Remote                interface{}
	INodes                interface{}
	TransferServiceStatus interface{}
}

type ForgetReq struct {
	Path string
}

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

type GetDirCompletion struct {
	DirEntries []DirEntry
	DirINode   INode
}

type GetDirRequest struct {
	GetDirListing          func(context.Context) ([]RemoteFile, error)
	DirINode               INode
	MakeDirEntriesCallback func(name string) func(inode INode)
	MakeFileCallback       func(name string, etag string) RequestCallback
	Response               chan error
}

type INode uint64

type INodeBlock struct {
	INode      INode
	BlockIndex int
}

type INodeStat struct {
	Size  int64
	IsDir bool
}

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

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

type INodesDiagnostics struct {
	NextINode   INode
	FreeINodes  int
	INodesInUse int
	Blocks      *BlocksDiagnostics
	BlockSize   int64
	WorkDir     string
}

type LazyDirectoryCallback struct {
	RequestDirEntries func(inode INode)
	RequestDirEntry   func(inode INode, name string)
}

type ListDirReq struct {
	Path string
}

type ListDirResp struct {
	Entries []FileClientDirEntry
}

type OpenReq struct {
	Path string
}

type OpenResp struct {
	FD int
}

type ReadReq struct {
	FD     int
	Length int
}

type ReadResp struct {
	Data []byte
}

type RemoteFile struct {
	Name  string
	IsDir bool
	ETag  string
	Size  int64
}

type RemoteProvider interface {
	GetDirListing(ctx context.Context, path string) ([]RemoteFile, error)
	GetReader(ctx context.Context, path string, ETag string, Offset int64, Length int64) (io.Reader, error)
	GetDiagnostics() interface{}
}

type ReqEnvelope struct {
	Type    string
	Payload json.RawMessage
}

type RequestCallback func(inode INode, blockIndices []int)

type RespEnvelope struct {
	Type    string
	Payload interface{}
}

type Response interface{}

type SeekReq struct {
	FD     int
	Offset int
	Whence string
}

type SeekResp struct {
	Offset int
}

type TransferServiceStatus struct {
	BlocksRequested         int
	ThreadsWaitingForBlocks int
	DirsRequested           int
	ThreadsWaitingForDirs   int
}

type WaitingThreads struct {
	Waiting []chan error
}