fs

Jan 21, 2025

Changes in this version

type FileSystem

+ func (fs *FileSystem) IsTicketAccess() bool

Jan 7, 2025

Changes in this version

type FileSystemCache

+ func (cache *FileSystemCache) RemoveDirEntryCache(path string, recursive bool)

+ func (cache *FileSystemCache) RemoveParentDirEntryCache(path string, recursive bool)

Sep 18, 2024

Changes in this version

type FileTransferResult

+ IRODSCheckSumAlgorithm types.ChecksumAlgorithm

+ LocalCheckSumAlgorithm types.ChecksumAlgorithm

Sep 12, 2024

Changes in this version

+ const FileSystemConnectionCreationTimeoutDefault

+ const FileSystemIOConnectionInitNumberDefault

+ const FileSystemIOConnectionMaxIdleNumberDefault

+ const FileSystemIOConnectionMaxNumberDefault

+ const FileSystemMetadataConnectionInitNumberDefault

+ const FileSystemMetadataConnectionMaxIdleNumberDefault

+ const FileSystemMetadataConnectionMaxNumberDefault

+ type CacheConfig struct

+ CleanupTime time.Duration

+ InvalidateParentEntryCacheImmediately bool

+ MetadataTimeoutSettings []MetadataCacheTimeoutSetting

+ StartNewTransaction bool

+ Timeout time.Duration

+ func NewDefaultCacheConfig() CacheConfig

+ type ConnectionConfig struct

+ CreationTimeout time.Duration

+ IdleTimeout time.Duration

+ InitNumber int

+ Lifespan time.Duration

+ MaxIdleNumber int

+ MaxNumber int

+ OperationTimeout time.Duration

+ TCPBufferSize int

+ func NewDefaultIOConnectionConfig() ConnectionConfig

+ func NewDefaultMetadataConnectionConfig() ConnectionConfig

type FileSystem

+ func (fs *FileSystem) Touch(irodsPath string, resource string, noCreate bool) error

type FileSystemConfig

+ AddressResolver session.AddressResolver

+ Cache CacheConfig

+ IOConnection ConnectionConfig

+ MetadataConnection ConnectionConfig

+ func (config *FileSystemConfig) ToIOSessionConfig() *session.IRODSSessionConfig

+ func (config *FileSystemConfig) ToMetadataSessionConfig() *session.IRODSSessionConfig

Jul 24, 2024

Changes in this version

+ type FileTransferResult struct

+ CheckSumAlgorithm types.ChecksumAlgorithm

+ EndTime time.Time

+ IRODSCheckSum []byte

+ IRODSPath string

+ IRODSSize int64

+ LocalCheckSum []byte

+ LocalPath string

+ LocalSize int64

+ StartTime time.Time

Jun 11, 2024

Changes in this version

+ const FileSystemChecksumAlgorithmDefault

type FileSystemConfig

+ ChecksumAlgorithm string

May 15, 2024

Changes in this version

type FileSystem

+ func (fs *FileSystem) GetDirACLInheritance(path string) (*types.IRODSAccessInheritance, error)

Mar 28, 2024

Changes in this version

type FileSystem

+ func (fs *FileSystem) AddResourceMetadata(resource string, attName, attValue, attUnits string) error

+ func (fs *FileSystem) DeleteMetadataByName(irodsPath string, attName string) error

+ func (fs *FileSystem) DeleteResourceMetadata(resource string, avuid int64) error

+ func (fs *FileSystem) DeleteResourceMetadataByName(resource string, attName string) error

+ func (fs *FileSystem) DeleteUserMetadataByName(user string, attName string) error

+ func (fs *FileSystem) ListResourceMetadata(resource string) ([]*types.IRODSMeta, error)

Mar 14, 2024

Changes in this version

type FileSystem

+ func NewFileSystemWithAddressResolver(account *types.IRODSAccount, config *FileSystemConfig, ...) (*FileSystem, error)

+ func (fs *FileSystem) DownloadFileRedirectToResource(irodsPath string, resource string, localPath string, ...) error

+ func (fs *FileSystem) UploadFileParallelRedirectToResource(localPath string, irodsPath string, resource string, replicate bool, ...) error

Feb 6, 2024

Changes in this version

type FileSystemCachePropagation

+ func (propagation *FileSystemCachePropagation) PropagateDirExtract(path string)

type FilesystemCacheEventHandlerMap

+ func (handlerMap *FilesystemCacheEventHandlerMap) SendDirExtractEvent(path string)

type FilesystemCacheEventType

+ const FilesystemCacheDirExtractEvent

Jan 18, 2024

Changes in this version

type FileSystem

+ func (fs *FileSystem) DownloadFileParallelResumable(irodsPath string, resource string, localPath string, taskNum int, ...) error

+ func (fs *FileSystem) DownloadFileResumable(irodsPath string, resource string, localPath string, ...) error

+ func (fs *FileSystem) UploadFileParallelResumable(localPath string, irodsPath string, resource string, taskNum int, ...) error

+ func (fs *FileSystem) UploadFileResumable(localPath string, irodsPath string, resource string, replicate bool, ...) error

type FileSystemConfig

+ TCPBufferSize int

Nov 16, 2023

Changes in this version

type Entry

+ func (entry *Entry) IsDir() bool

Oct 30, 2023

Changes in this version

+ const FileSystemConnectionErrorTimeoutDefault

+ const FileSystemConnectionInitNumberDefault

+ const FileSystemConnectionLifespanDefault

+ const FileSystemTCPBufferSizeDefault

type FileSystemConfig

+ ConnectionErrorTimeout time.Duration

+ ConnectionInitNumber int

Oct 11, 2023

Changes in this version

type Entry

+ CheckSumAlgorithm string

Aug 22, 2023

Changes in this version

type FileHandle

+ func (handle *FileHandle) LockDataObject(wait bool) error

+ func (handle *FileHandle) RLockDataObject(wait bool) error

+ func (handle *FileHandle) UnlockDataObject() error

type FileSystem

+ func (fs *FileSystem) DownloadFileToBuffer(irodsPath string, resource string, buffer bytes.Buffer, ...) error

+ func (fs *FileSystem) UploadFileFromBuffer(buffer bytes.Buffer, irodsPath string, resource string, replicate bool, ...) error

May 24, 2023

Changes in this version

type FileSystem

+ func (fs *FileSystem) GetTicket(ticketName string) (*types.IRODSTicket, error)

May 23, 2023

Changes in this version

type FileSystem

+ func (fs *FileSystem) AddTicketAllowedGroup(ticketName string, groupName string) error

+ func (fs *FileSystem) AddTicketAllowedHost(ticketName string, host string) error

+ func (fs *FileSystem) AddTicketAllowedUser(ticketName string, userName string) error

+ func (fs *FileSystem) ClearTicketExpirationTime(ticketName string) error

+ func (fs *FileSystem) ClearTicketUseLimit(ticketName string) error

+ func (fs *FileSystem) ClearTicketWriteByteLimit(ticketName string) error

+ func (fs *FileSystem) ClearTicketWriteFileLimit(ticketName string) error

+ func (fs *FileSystem) CreateTicket(ticketName string, ticketType types.TicketType, path string) error

+ func (fs *FileSystem) DeleteTicket(ticketName string) error

+ func (fs *FileSystem) GetTicketRestrictions(ticketID int64) (*IRODSTicketRestrictions, error)

+ func (fs *FileSystem) ListTicketHostRestrictions(ticketID int64) ([]string, error)

+ func (fs *FileSystem) ListTicketUserGroupRestrictions(ticketID int64) ([]string, error)

+ func (fs *FileSystem) ListTicketUserNameRestrictions(ticketID int64) ([]string, error)

+ func (fs *FileSystem) ListTickets() ([]*types.IRODSTicket, error)

+ func (fs *FileSystem) ListTicketsBasic() ([]*types.IRODSTicket, error)

+ func (fs *FileSystem) ModifyTicketExpirationTime(ticketName string, expirationTime time.Time) error

+ func (fs *FileSystem) ModifyTicketUseLimit(ticketName string, uses int) error

+ func (fs *FileSystem) ModifyTicketWriteByteLimit(ticketName string, bytes int) error

+ func (fs *FileSystem) ModifyTicketWriteFileLimit(ticketName string, count int) error

+ func (fs *FileSystem) RemoveTicketAllowedGroup(ticketName string, groupName string) error

+ func (fs *FileSystem) RemoveTicketAllowedHost(ticketName string, host string) error

+ func (fs *FileSystem) RemoveTicketAllowedUser(ticketName string, userName string) error

+ type IRODSTicketRestrictions struct

+ AllowedGroupNames []string

+ AllowedHosts []string

+ AllowedUserNames []string

+ func (ticket *IRODSTicketRestrictions) ToString() string

Apr 8, 2023

Changes in this version

type FileSystem

+ func (fs *FileSystem) UploadFileAsync(localPath string, irodsPath string, resource string, replicate bool, ...) error

Mar 2, 2023

Changes in this version

+ const FileSystemConnectionMetaDefault

+ const TCPBufferSizeDefault

type FileSystem

+ func (fs *FileSystem) GetIOConnection() (*connection.IRODSConnection, error)

+ func (fs *FileSystem) GetMetadataConnection() (*connection.IRODSConnection, error)

+ func (fs *FileSystem) ReturnIOConnection(conn *connection.IRODSConnection)

+ func (fs *FileSystem) ReturnMetadataConnection(conn *connection.IRODSConnection)

type FileSystemConfig

+ TcpBufferSize int

Feb 15, 2023

Changes in this version

type FileSystem

+ func (fs *FileSystem) GetConnection() (*connection.IRODSConnection, error)

+ func (fs *FileSystem) ReturnConnection(conn *connection.IRODSConnection)

Feb 9, 2023

Changes in this version

type FileSystem

+ func (fs *FileSystem) GetServerVersion() (*types.IRODSVersion, error)

+ func (fs *FileSystem) SupportParallelUpload() bool

Jan 19, 2023

Changes in this version

type FileSystem

+ func (fs *FileSystem) AddCacheEventHandler(handler FilesystemCacheEventHandler) string

+ func (fs *FileSystem) RemoveCacheEventHandler(handlerID string)

+ type FilesystemCacheEventHandler func(path string, eventType FilesystemCacheEventType)

+ type FilesystemCacheEventHandlerMap struct

+ func NewFilesystemCacheEventHandlerMap() *FilesystemCacheEventHandlerMap

+ func (handlerMap *FilesystemCacheEventHandlerMap) AddEventHandler(handler FilesystemCacheEventHandler) string

+ func (handlerMap *FilesystemCacheEventHandlerMap) GetEventHandler(handlerID string) FilesystemCacheEventHandler

+ func (handlerMap *FilesystemCacheEventHandlerMap) GetEventHandlerIDs() []string

+ func (handlerMap *FilesystemCacheEventHandlerMap) GetEventHandlers() []FilesystemCacheEventHandler

+ func (handlerMap *FilesystemCacheEventHandlerMap) Release()

+ func (handlerMap *FilesystemCacheEventHandlerMap) RemoveEventHandler(handlerID string)

+ func (handlerMap *FilesystemCacheEventHandlerMap) SendDirCreateEvent(path string)

+ func (handlerMap *FilesystemCacheEventHandlerMap) SendDirRemoveEvent(path string)

+ func (handlerMap *FilesystemCacheEventHandlerMap) SendEvent(path string, eventType FilesystemCacheEventType)

+ func (handlerMap *FilesystemCacheEventHandlerMap) SendFileCreateEvent(path string)

+ func (handlerMap *FilesystemCacheEventHandlerMap) SendFileRemoveEvent(path string)

+ func (handlerMap *FilesystemCacheEventHandlerMap) SendFileUpdateEvent(path string)

+ type FilesystemCacheEventType string

Dec 21, 2022

Changes in this version

type FileSystem

+ func (fs *FileSystem) AddCacheUpdateEventHandler(handler FilesystemCacheUpdateEventHandler) string

+ func (fs *FileSystem) RemoveCacheUpdateEventHandler(handlerID string)

+ type FilesystemCacheUpdateEventHandler func(path string, eventType FilesystemCacheUpdateEventType)

+ type FilesystemCacheUpdateEventHandlerMap struct

+ func NewFilesystemCacheUpdateEventHandlerMap() *FilesystemCacheUpdateEventHandlerMap

+ func (handlerMap *FilesystemCacheUpdateEventHandlerMap) AddEventHandler(handler FilesystemCacheUpdateEventHandler) string

+ func (handlerMap *FilesystemCacheUpdateEventHandlerMap) GetEventHandler(handlerID string) FilesystemCacheUpdateEventHandler

+ func (handlerMap *FilesystemCacheUpdateEventHandlerMap) GetEventHandlerIDs() []string

+ func (handlerMap *FilesystemCacheUpdateEventHandlerMap) GetEventHandlers() []FilesystemCacheUpdateEventHandler

+ func (handlerMap *FilesystemCacheUpdateEventHandlerMap) Release()

+ func (handlerMap *FilesystemCacheUpdateEventHandlerMap) RemoveEventHandler(handlerID string)

+ func (handlerMap *FilesystemCacheUpdateEventHandlerMap) SendDirCreateEvent(path string)

+ func (handlerMap *FilesystemCacheUpdateEventHandlerMap) SendDirRemoveEvent(path string)

+ func (handlerMap *FilesystemCacheUpdateEventHandlerMap) SendEvent(path string, eventType FilesystemCacheUpdateEventType)

+ func (handlerMap *FilesystemCacheUpdateEventHandlerMap) SendFileCreateEvent(path string)

+ func (handlerMap *FilesystemCacheUpdateEventHandlerMap) SendFileRemoveEvent(path string)

+ func (handlerMap *FilesystemCacheUpdateEventHandlerMap) SendFileUpdateEvent(path string)

Aug 29, 2022

Changes in this version

type FileSystem

+ func (fs *FileSystem) ConnectionTotal() int

+ func (fs *FileSystem) GetMetrics() *metrics.IRODSMetrics

+ func (fs *FileSystem) ListAllProcesses() ([]*types.IRODSProcess, error)

+ func (fs *FileSystem) ListProcesses(address string, zone string) ([]*types.IRODSProcess, error)

Jul 22, 2022

Changes in this version

type Entry

+ DataType string

type FileSystem

+ func (fs *FileSystem) ExtractStructFile(path string, targetCollection string, resource string, dataType types.DataType, ...) error

+ func (fs *FileSystem) ListACLsForEntries(path string) ([]*types.IRODSAccess, error)

type FileSystemCache

+ func (cache *FileSystemCache) AddACLsCache(path string, accesses []*types.IRODSAccess)

+ func (cache *FileSystemCache) AddACLsCacheMulti(accesses []*types.IRODSAccess)

+ func (cache *FileSystemCache) ClearACLsCache()

+ func (cache *FileSystemCache) GetACLsCache(path string) []*types.IRODSAccess

+ func (cache *FileSystemCache) RemoveACLsCache(path string)

May 25, 2022

Changes in this version

type FileHandleMap

+ func (fileHandleMap *FileHandleMap) AddCloseEventHandler(path string, handler FileHandleMapEventHandler) string

+ func (fileHandleMap *FileHandleMap) RemoveCloseEventHandler(handlerID string)

+ type FileHandleMapEventHandler func(path string, id string, empty bool)

+ type FileHandleMapEventHandlerWrap struct

May 2, 2022

Changes in this version

type FileSystem

+ func (fs *FileSystem) GetID() string

+ type FileSystemCachePropagation struct

+ func NewFileSystemCachePropagation(fs *FileSystem) *FileSystemCachePropagation

+ func (propagation *FileSystemCachePropagation) Propagate(path string, eventType FilesystemCacheUpdateEventType)

+ func (propagation *FileSystemCachePropagation) PropagateDirCreate(path string)

+ func (propagation *FileSystemCachePropagation) PropagateDirRemove(path string)

+ func (propagation *FileSystemCachePropagation) PropagateFileCreate(path string)

+ func (propagation *FileSystemCachePropagation) PropagateFileRemove(path string)

+ func (propagation *FileSystemCachePropagation) PropagateFileUpdate(path string)

+ func (propagation *FileSystemCachePropagation) Release()

+ type FilesystemCacheUpdateEventType string

+ const FilesystemCacheDirCreateEvent

+ const FilesystemCacheDirRemoveEvent

+ const FilesystemCacheFileCreateEvent

+ const FilesystemCacheFileRemoveEvent

+ const FilesystemCacheFileUpdateEvent

+ type FilesystemCacheUpdatedFunc func(path string, eventType FilesystemCacheUpdateEventType)

Mar 25, 2022

Changes in this version

type FileHandle

+ func (handle *FileHandle) IsReadOnlyMode() bool

+ func (handle *FileHandle) IsWriteOnlyMode() bool

Mar 16, 2022

Changes in this version

type FileHandle

+ func (handle *FileHandle) GetEntry() *Entry

+ func (handle *FileHandle) GetID() string

+ func (handle *FileHandle) GetIRODSFileHandle() *types.IRODSFileHandle

+ func (handle *FileHandle) GetOpenMode() types.FileOpenMode

+ func (handle *FileHandle) Lock()

+ func (handle *FileHandle) Unlock()

+ type FileHandleMap struct

+ func NewFileHandleMap() *FileHandleMap

+ func (fileHandleMap *FileHandleMap) Add(handle *FileHandle)

+ func (fileHandleMap *FileHandleMap) Clear()

+ func (fileHandleMap *FileHandleMap) Get(id string) *FileHandle

+ func (fileHandleMap *FileHandleMap) List() []*FileHandle

+ func (fileHandleMap *FileHandleMap) ListByPath(path string) []*FileHandle

+ func (fileHandleMap *FileHandleMap) ListPathsInDir(parentPath string) []string

+ func (fileHandleMap *FileHandleMap) Pop(id string) *FileHandle

+ func (fileHandleMap *FileHandleMap) PopAll() []*FileHandle

+ func (fileHandleMap *FileHandleMap) PopByPath(path string) []*FileHandle

+ func (fileHandleMap *FileHandleMap) Remove(id string)

Feb 25, 2022

Changes in this version

type FileHandle

+ func (handle *FileHandle) Truncate(size int64) error

+ type FileLock struct

+ type FileLocks struct

+ func NewFileLocks() *FileLocks

+ func (mgr *FileLocks) Lock(path string)

+ func (mgr *FileLocks) LockFilesForPrefix(pathPrefix string) []string

+ func (mgr *FileLocks) RLock(path string)

+ func (mgr *FileLocks) RUnlock(path string) error

+ func (mgr *FileLocks) Unlock(path string) error

+ func (mgr *FileLocks) UnlockFiles(paths []string) error

type FileSystem

+ func (fs *FileSystem) GetTicketForAnonymousAccess(ticket string) (*types.IRODSTicketForAnonymousAccess, error)

+ func (fs *FileSystem) GetTransferMetrics() types.TransferMetrics

type FileSystemCache

+ func (cache *FileSystemCache) AddNegativeEntryCache(path string)

+ func (cache *FileSystemCache) ClearNegativeEntryCache()

+ func (cache *FileSystemCache) HasNegativeEntryCache(path string) bool

+ func (cache *FileSystemCache) RemoveAllNegativeEntryCacheForPath(path string)

+ func (cache *FileSystemCache) RemoveNegativeEntryCache(path string)

+ func (cache *FileSystemCache) RemoveParentDirCache(path string)

type FileSystemConfig

+ InvalidateParentEntryCacheImmediately bool

Jan 24, 2022

Changes in this version

type FileSystemConfig

+ CacheTimeoutSettings []MetadataCacheTimeoutSetting

+ type MetadataCacheTimeoutSetting struct

+ Inherit bool

+ Path string

+ Timeout time.Duration

Jan 22, 2022

Changes in this version

+ const ConnectionLifespanDefault

type FileSystemConfig

+ CacheTimeoutPathMap map[string]time.Duration

+ ConnectionLifespan time.Duration

Nov 1, 2021

Changes in this version

type FileSystem

+ func (fs *FileSystem) ListUserGroups(user string) ([]*types.IRODSUser, error)

type FileSystemCache

+ UserGroupsCache *gocache.Cache

+ func (cache *FileSystemCache) AddUserGroupsCache(user string, groups []*types.IRODSUser)

+ func (cache *FileSystemCache) GetUserGroupsCache(user string) []*types.IRODSUser

+ func (cache *FileSystemCache) RemoveUserGroupsCache(user string)

Sep 23, 2021

Changes in this version

type FileHandle

+ ID string

+ Mutex sync.Mutex

+ func (handle *FileHandle) ReadAt(offset int64, length int) ([]byte, error)

+ func (handle *FileHandle) WriteAt(offset int64, data []byte) error

type FileSystem

+ FileHandles map[string]*FileHandle

+ Mutex sync.Mutex

+ func NewFileSystemWithSessionConfig(account *types.IRODSAccount, sessConfig *session.IRODSSessionConfig) (*FileSystem, error)

+ func (fs *FileSystem) Connections() int

Aug 30, 2021

Changes in this version

+ const FileSystemConnectionMaxDefault

+ const FileSystemConnectionMaxMin

+ const FileSystemTimeoutDefault

+ type Entry struct

+ CheckSum string

+ CreateTime time.Time

+ ID int64

+ Internal interface{}

+ ModifyTime time.Time

+ Name string

+ Owner string

+ Path string

+ Size int64

+ Type EntryType

+ func (entry *Entry) ToString() string

+ type EntryType string

+ const DirectoryEntry

+ const FileEntry

type FileSystem

+ func (fs *FileSystem) DownloadFileParallel(irodsPath string, resource string, localPath string, taskNum int) error

+ func (fs *FileSystem) DownloadFileParallelInBlocksAsync(irodsPath string, resource string, localPath string, blockLength int64, ...) (chan int64, chan error)

+ func (fs *FileSystem) UploadFileParallel(localPath string, irodsPath string, resource string, taskNum int, ...) error

+ func (fs *FileSystem) UploadFileParallelInBlocksAsync(localPath string, irodsPath string, resource string, blockLength int64, ...) (chan int64, chan error)

Jun 14, 2021

Changes in this version

type FileSystem

+ func (fs *FileSystem) AddUserMetadata(user string, avuid int64, attName, attValue, attUnits string) error

+ func (fs *FileSystem) DeleteUserMetadata(user string, avuid int64, attName, attValue, attUnits string) error

+ func (fs *FileSystem) ListGroups() ([]*types.IRODSUser, error)

+ func (fs *FileSystem) ListUserMetadata(user string) ([]*types.IRODSMeta, error)

+ func (fs *FileSystem) ListUsers() ([]*types.IRODSUser, error)

type FileSystemCache

+ DirACLsCache *gocache.Cache

+ FileACLsCache *gocache.Cache

+ GroupsCache *gocache.Cache

+ UsersCache *gocache.Cache

+ func (cache *FileSystemCache) AddDirACLsCache(path string, accesses []*types.IRODSAccess)

+ func (cache *FileSystemCache) AddFileACLsCache(path string, accesses []*types.IRODSAccess)

+ func (cache *FileSystemCache) AddGroupsCache(groups []*types.IRODSUser)

+ func (cache *FileSystemCache) AddUsersCache(users []*types.IRODSUser)

+ func (cache *FileSystemCache) ClearDirACLsCache()

+ func (cache *FileSystemCache) ClearFileACLsCache()

+ func (cache *FileSystemCache) GetDirACLsCache(path string) []*types.IRODSAccess

+ func (cache *FileSystemCache) GetFileACLsCache(path string) []*types.IRODSAccess

+ func (cache *FileSystemCache) GetGroupsCache() []*types.IRODSUser

+ func (cache *FileSystemCache) GetUsersCache() []*types.IRODSUser

+ func (cache *FileSystemCache) RemoveDirACLsCache(path string)

+ func (cache *FileSystemCache) RemoveFileACLsCache(path string)

+ func (cache *FileSystemCache) RemoveGroupsCache()

+ func (cache *FileSystemCache) RemoveUsersCache()

Apr 5, 2021

Changes in this version

type FileSystemConfig

+ StartNewTransaction bool

Mar 23, 2021

Changes in this version

type FileSystem

+ func (fs *FileSystem) SearchByMeta(metaname string, metavalue string) ([]*FSEntry, error)

Mar 17, 2021

Changes in this version

type FileSystem

+ func (fs *FileSystem) AddMetadata(irodsPath string, attName string, attValue string, attUnits string) error

+ func (fs *FileSystem) DeleteMetadata(irodsPath string, attName string, attValue string, attUnits string) error

+ func (fs *FileSystem) ListMetadata(path string) ([]*types.IRODSMeta, error)

type FileSystemCache

+ MetadataCache *gocache.Cache

+ func (cache *FileSystemCache) AddMetadataCache(path string, metas []*types.IRODSMeta)

+ func (cache *FileSystemCache) ClearMetadataCache()

+ func (cache *FileSystemCache) GetMetadataCache(path string) []*types.IRODSMeta

+ func (cache *FileSystemCache) RemoveMetadataCache(path string)

Mar 8, 2021

Changes in this version

type FileSystem

+ func (fs *FileSystem) ListACLs(path string) ([]*types.IRODSAccess, error)

+ func (fs *FileSystem) ListACLsWithGroupUsers(path string) ([]*types.IRODSAccess, error)

+ func (fs *FileSystem) ListDirACLs(path string) ([]*types.IRODSAccess, error)

+ func (fs *FileSystem) ListDirACLsWithGroupUsers(path string) ([]*types.IRODSAccess, error)

+ func (fs *FileSystem) ListFileACLs(path string) ([]*types.IRODSAccess, error)

+ func (fs *FileSystem) ListFileACLsWithGroupUsers(path string) ([]*types.IRODSAccess, error)

+ func (fs *FileSystem) ListGroupUsers(group string) ([]*types.IRODSUser, error)

type FileSystemCache

+ GroupUsersCache *gocache.Cache

+ func (cache *FileSystemCache) AddGroupUsersCache(group string, users []types.IRODSUser)

+ func (cache *FileSystemCache) GetGroupUsersCache(group string) []types.IRODSUser

+ func (cache *FileSystemCache) RemoveGroupUsersCache(group string)

Feb 17, 2021

Changes in this version

+ type FSEntry struct

+ CheckSum string

+ CreateTime time.Time

+ ID int64

+ Internal interface{}

+ ModifyTime time.Time

+ Name string

+ Owner string

+ Path string

+ Size int64

+ Type FSEntryType

+ func (entry *FSEntry) ToString() string

+ type FSEntryType string

+ const FSDirectoryEntry

+ const FSFileEntry

+ type FileHandle struct

+ Connection *connection.IRODSConnection

+ Entry *FSEntry

+ FileSystem *FileSystem

+ IRODSHandle *types.IRODSFileHandle

+ Offset int64

+ OpenMode types.FileOpenMode

+ func (handle *FileHandle) Close() error

+ func (handle *FileHandle) GetOffset() int64

+ func (handle *FileHandle) IsReadMode() bool

+ func (handle *FileHandle) IsWriteMode() bool

+ func (handle *FileHandle) Read(length int) ([]byte, error)

+ func (handle *FileHandle) Seek(offset int64, whence types.Whence) (int64, error)

+ func (handle *FileHandle) ToString() string

+ func (handle *FileHandle) Write(data []byte) error

+ type FileSystem struct

+ Account *types.IRODSAccount

+ Cache *FileSystemCache

+ Config *FileSystemConfig

+ Session *session.IRODSSession

+ func NewFileSystem(account *types.IRODSAccount, config *FileSystemConfig) *FileSystem

+ func NewFileSystemWithDefault(account *types.IRODSAccount, applicationName string) *FileSystem

+ func (fs *FileSystem) ClearCache()

+ func (fs *FileSystem) CopyFile(srcPath string, destPath string) error

+ func (fs *FileSystem) CopyFileToFile(srcPath string, destPath string) error

+ func (fs *FileSystem) CreateFile(path string, resource string) (*FileHandle, error)

+ func (fs *FileSystem) DownloadFile(irodsPath string, localPath string) error

+ func (fs *FileSystem) Exists(path string) bool

+ func (fs *FileSystem) ExistsDir(path string) bool

+ func (fs *FileSystem) ExistsFile(path string) bool

+ func (fs *FileSystem) InvalidateCache(path string)

+ func (fs *FileSystem) List(path string) ([]*FSEntry, error)

+ func (fs *FileSystem) MakeDir(path string, recurse bool) error

+ func (fs *FileSystem) OpenFile(path string, resource string, mode string) (*FileHandle, error)

+ func (fs *FileSystem) Release()

+ func (fs *FileSystem) RemoveDir(path string, recurse bool, force bool) error

+ func (fs *FileSystem) RemoveFile(path string, force bool) error

+ func (fs *FileSystem) RenameDir(srcPath string, destPath string) error

+ func (fs *FileSystem) RenameDirToDir(srcPath string, destPath string) error

+ func (fs *FileSystem) RenameFile(srcPath string, destPath string) error

+ func (fs *FileSystem) RenameFileToFile(srcPath string, destPath string) error

+ func (fs *FileSystem) ReplicateFile(path string, resource string, update bool) error

+ func (fs *FileSystem) Stat(path string) (*FSEntry, error)

+ func (fs *FileSystem) StatDir(path string) (*FSEntry, error)

+ func (fs *FileSystem) StatFile(path string) (*FSEntry, error)

+ func (fs *FileSystem) TruncateFile(path string, size int64) error

+ func (fs *FileSystem) UploadFile(localPath string, irodsPath string, resource string, replicate bool) error

+ type FileSystemCache struct

+ CacheTimeout time.Duration

+ CleanupTimeout time.Duration

+ DirCache *gocache.Cache

+ EntryCache *gocache.Cache

+ func NewFileSystemCache(cacheTimeout time.Duration, cleanup time.Duration) *FileSystemCache

+ func (cache *FileSystemCache) AddDirCache(path string, entries []string)

+ func (cache *FileSystemCache) AddEntryCache(entry *FSEntry)

+ func (cache *FileSystemCache) ClearDirCache()

+ func (cache *FileSystemCache) ClearEntryCache()

+ func (cache *FileSystemCache) GetDirCache(path string) []string

+ func (cache *FileSystemCache) GetEntryCache(path string) *FSEntry

+ func (cache *FileSystemCache) RemoveDirCache(path string)

+ func (cache *FileSystemCache) RemoveEntryCache(path string)

+ type FileSystemConfig struct

+ ApplicationName string

+ CacheCleanupTime time.Duration

+ CacheTimeout time.Duration

+ ConnectionIdleTimeout time.Duration

+ ConnectionMax int

+ OperationTimeout time.Duration

+ func NewFileSystemConfig(applicationName string, operationTimeout time.Duration, ...) *FileSystemConfig

+ func NewFileSystemConfigWithDefault(applicationName string) *FileSystemConfig