client

package
v0.6.23 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Mar 22, 2024 License: BSD-3-Clause Imports: 16 Imported by: 1

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type MetadataCache added in v0.5.9 

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

MetadataCache manages filesystem metadata caches

func NewMetadataCache added in v0.5.9 

func NewMetadataCache(cacheTimeout time.Duration, cleanup time.Duration) *MetadataCache

NewMetadataCache creates a new MetadataCache

func (*MetadataCache) AddACLsCache added in v0.5.9 

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

AddACLsCache adds a ACLs cache

func (*MetadataCache) AddACLsCacheMulti added in v0.5.9 

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

AddACLsCache adds multiple ACLs caches

func (*MetadataCache) AddDirCache added in v0.5.9 

func (cache *MetadataCache) AddDirCache(path string, entries []*irodsclient_fs.Entry)

AddDirCache adds a dir cache

func (*MetadataCache) AddDirEntryACLsCache added in v0.5.9 

func (cache *MetadataCache) AddDirEntryACLsCache(path string, accesses []*types.IRODSAccess)

AddDirEntryACLsCache adds a ACLs cache

func (*MetadataCache) AddEntryCache added in v0.5.9 

func (cache *MetadataCache) AddEntryCache(entry *irodsclient_fs.Entry)

AddEntryCache adds an entry cache

func (*MetadataCache) ClearACLsCache added in v0.5.9 

func (cache *MetadataCache) ClearACLsCache()

ClearACLsCache clears all ACLs caches

func (*MetadataCache) ClearDirCache added in v0.5.9 

func (cache *MetadataCache) ClearDirCache()

ClearDirCache clears all dir caches

func (*MetadataCache) ClearDirEntryACLsCache added in v0.5.9 

func (cache *MetadataCache) ClearDirEntryACLsCache()

ClearDirEntryACLsCache clears all ACLs caches

func (*MetadataCache) ClearEntryCache added in v0.5.9 

func (cache *MetadataCache) ClearEntryCache()

ClearEntryCache clears all entry caches

func (*MetadataCache) GetACLsCache added in v0.5.9 

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

GetACLsCache retrives a ACLs cache

func (*MetadataCache) GetDirCache added in v0.5.9 

func (cache *MetadataCache) GetDirCache(path string) []*irodsclient_fs.Entry

GetDirCache retrives a dir cache

func (*MetadataCache) GetDirEntryACLsCache added in v0.5.9 

func (cache *MetadataCache) GetDirEntryACLsCache(path string) []*types.IRODSAccess

GetDirEntryACLsCache retrives a ACLs cache

func (*MetadataCache) GetEntryCache added in v0.5.9 

func (cache *MetadataCache) GetEntryCache(path string) *irodsclient_fs.Entry

GetEntryCache retrieves an entry cache

func (*MetadataCache) RemoveACLsCache added in v0.5.9 

func (cache *MetadataCache) RemoveACLsCache(path string)

RemoveACLsCache removes a ACLs cache

func (*MetadataCache) RemoveDirCache added in v0.5.9 

func (cache *MetadataCache) RemoveDirCache(path string)

RemoveDirCache removes a dir cache

func (*MetadataCache) RemoveDirEntryACLsCache added in v0.5.9 

func (cache *MetadataCache) RemoveDirEntryACLsCache(path string)

RemoveDirEntryACLsCache removes a ACLs cache

func (*MetadataCache) RemoveEntryCache added in v0.5.9 

func (cache *MetadataCache) RemoveEntryCache(path string)

RemoveEntryCache removes an entry cache

type PoolServiceClient 

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

PoolServiceClient is a client of pool service

func NewPoolServiceClient 

func NewPoolServiceClient(address string, operationTimeout time.Duration, clientID string) *PoolServiceClient

NewPoolServiceClient creates a new pool service client

func (*PoolServiceClient) Connect 

func (client *PoolServiceClient) Connect() error

Connect connects to pool service

func (*PoolServiceClient) Disconnect 

func (client *PoolServiceClient) Disconnect()

Disconnect disconnects connection from pool service

func (*PoolServiceClient) NewSession added in v0.5.0 

func (client *PoolServiceClient) NewSession(account *irodsclient_types.IRODSAccount, applicationName string) (irodsfs_common_irods.IRODSFSClient, error)

NewSession creates a new session for iRODS service using account info

type PoolServiceFileHandle 

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

PoolServiceFileHandle implements IRODSFSFileHandle

func (*PoolServiceFileHandle) Close added in v0.5.0 

func (handle *PoolServiceFileHandle) Close() error

Close closes iRODS data object handle

func (*PoolServiceFileHandle) Flush added in v0.5.0 

func (handle *PoolServiceFileHandle) Flush() error

Flush flushes iRODS data object handle

func (*PoolServiceFileHandle) GetAvailable added in v0.5.4 

func (handle *PoolServiceFileHandle) GetAvailable(offset int64) int64

GetAvailable returns available len for read

func (*PoolServiceFileHandle) GetEntry added in v0.3.5 

func (handle *PoolServiceFileHandle) GetEntry() *irodsclient_fs.Entry

func (*PoolServiceFileHandle) GetID added in v0.5.0 

func (handle *PoolServiceFileHandle) GetID() string

func (*PoolServiceFileHandle) GetOffset added in v0.5.0 

func (handle *PoolServiceFileHandle) GetOffset() int64

GetOffset returns current offset

func (*PoolServiceFileHandle) GetOpenMode added in v0.3.5 

func (handle *PoolServiceFileHandle) GetOpenMode() irodsclient_types.FileOpenMode

func (*PoolServiceFileHandle) IsReadMode 

func (handle *PoolServiceFileHandle) IsReadMode() bool

func (*PoolServiceFileHandle) IsWriteMode 

func (handle *PoolServiceFileHandle) IsWriteMode() bool

func (*PoolServiceFileHandle) Lock added in v0.6.15 

func (handle *PoolServiceFileHandle) Lock(wait bool) error

Lock locks iRODS data object

func (*PoolServiceFileHandle) RLock added in v0.6.15 

func (handle *PoolServiceFileHandle) RLock(wait bool) error

RLock locks iRODS data object with read lock

func (*PoolServiceFileHandle) ReadAt added in v0.5.0 

func (handle *PoolServiceFileHandle) ReadAt(buffer []byte, offset int64) (int, error)

ReadAt reads iRODS data object

func (*PoolServiceFileHandle) Truncate added in v0.5.0 

func (handle *PoolServiceFileHandle) Truncate(size int64) error

Truncate truncates iRODS data object

func (*PoolServiceFileHandle) Unlock added in v0.6.15 

func (handle *PoolServiceFileHandle) Unlock() error

Unlock unlocks iRODS data object with read lock

func (*PoolServiceFileHandle) WriteAt added in v0.5.0 

func (handle *PoolServiceFileHandle) WriteAt(data []byte, offset int64) (int, error)

WriteAt writes iRODS data object

type PoolServiceSession 

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

PoolServiceSession is a service session implements irodsfs-common/irods/interface.go

func (*PoolServiceSession) AddCacheEventHandler added in v0.6.7 

func (session *PoolServiceSession) AddCacheEventHandler(handler irodsclient_fs.FilesystemCacheEventHandler) (string, error)

AddCacheEventHandler adds a cache event handler

func (*PoolServiceSession) CreateFile added in v0.5.0 

func (session *PoolServiceSession) CreateFile(path string, resource string, mode string) (irodsfs_common_irods.IRODSFSFileHandle, error)

CreateFile creates a new iRODS data object

func (*PoolServiceSession) ExistsDir added in v0.5.0 

func (session *PoolServiceSession) ExistsDir(path string) bool

ExistsDir checks existence of Dir

func (*PoolServiceSession) ExistsFile added in v0.5.0 

func (session *PoolServiceSession) ExistsFile(path string) bool

ExistsFile checks existence of File

func (*PoolServiceSession) GetAccount added in v0.5.0 

func (session *PoolServiceSession) GetAccount() *irodsclient_types.IRODSAccount

func (*PoolServiceSession) GetApplicationName added in v0.5.0 

func (session *PoolServiceSession) GetApplicationName() string

func (*PoolServiceSession) GetConnections added in v0.5.0 

func (session *PoolServiceSession) GetConnections() int

func (*PoolServiceSession) GetMetrics added in v0.5.13 

func (session *PoolServiceSession) GetMetrics() *irodsclient_metrics.IRODSMetrics

func (*PoolServiceSession) GetXattr added in v0.6.0 

func (session *PoolServiceSession) GetXattr(path string, name string) (*irodsclient_types.IRODSMeta, error)

GetXattr returns iRODS metadata (xattr)

func (*PoolServiceSession) InvalidateCacheForCreateFile added in v0.6.12 

func (session *PoolServiceSession) InvalidateCacheForCreateFile(path string)

InvalidateCacheForCreateFile removes caches for file

func (*PoolServiceSession) InvalidateCacheForMakeDir added in v0.6.12 

func (session *PoolServiceSession) InvalidateCacheForMakeDir(path string)

InvalidateCacheForMakeDir removes caches for dir

func (*PoolServiceSession) InvalidateCacheForRemoveDir added in v0.6.12 

func (session *PoolServiceSession) InvalidateCacheForRemoveDir(path string)

InvalidateCacheForRemoveDir removes caches for dir

func (*PoolServiceSession) InvalidateCacheForRemoveFile added in v0.6.12 

func (session *PoolServiceSession) InvalidateCacheForRemoveFile(path string)

InvalidateCacheForRemoveFile removes caches for file

func (*PoolServiceSession) InvalidateCacheForRenameDir added in v0.6.12 

func (session *PoolServiceSession) InvalidateCacheForRenameDir(srcPath string, destPath string)

InvalidateCacheForRenameDir removes caches for dir

func (*PoolServiceSession) InvalidateCacheForRenameFile added in v0.6.12 

func (session *PoolServiceSession) InvalidateCacheForRenameFile(srcPath string, destPath string)

InvalidateCacheForRenameFile removes caches for file

func (*PoolServiceSession) InvalidateCacheForUpdateFile added in v0.6.12 

func (session *PoolServiceSession) InvalidateCacheForUpdateFile(path string)

InvalidateCacheForUpdateFile removes caches for file

func (*PoolServiceSession) List added in v0.5.0 

func (session *PoolServiceSession) List(path string) ([]*irodsclient_fs.Entry, error)

List lists iRODS collection entries

func (*PoolServiceSession) ListACLsForEntries added in v0.5.8 

func (session *PoolServiceSession) ListACLsForEntries(path string) ([]*irodsclient_types.IRODSAccess, error)

ListACLsForEntries lists ACLs for entries in an iRODS collection

func (*PoolServiceSession) ListDirACLs added in v0.5.0 

func (session *PoolServiceSession) ListDirACLs(path string) ([]*irodsclient_types.IRODSAccess, error)

ListDirACLs lists iRODS collection ACLs

func (*PoolServiceSession) ListFileACLs added in v0.5.0 

func (session *PoolServiceSession) ListFileACLs(path string) ([]*irodsclient_types.IRODSAccess, error)

ListFileACLs lists iRODS data object ACLs

func (*PoolServiceSession) ListUserGroups added in v0.5.0 

func (session *PoolServiceSession) ListUserGroups(user string) ([]*irodsclient_types.IRODSUser, error)

ListUserGroups lists iRODS Groups that a user belongs to

func (*PoolServiceSession) ListXattr added in v0.6.0 

func (session *PoolServiceSession) ListXattr(path string) ([]*irodsclient_types.IRODSMeta, error)

ListXattr lists iRODS metadata (xattr)

func (*PoolServiceSession) MakeDir added in v0.5.0 

func (session *PoolServiceSession) MakeDir(path string, recurse bool) error

MakeDir creates a new iRODS collection

func (*PoolServiceSession) OpenFile added in v0.5.0 

func (session *PoolServiceSession) OpenFile(path string, resource string, mode string) (irodsfs_common_irods.IRODSFSFileHandle, error)

OpenFile opens iRODS data object

func (*PoolServiceSession) Release added in v0.5.0 

func (session *PoolServiceSession) Release()

Release logouts from iRODS service session

func (*PoolServiceSession) Relogin added in v0.6.0 

func (session *PoolServiceSession) Relogin() error

Relogin re-login iRODS service session

func (*PoolServiceSession) RemoveCacheEventHandler added in v0.6.7 

func (session *PoolServiceSession) RemoveCacheEventHandler(handlerID string) error

RemoveCacheEventHandler removes a cache event handler with the given handler ID

func (*PoolServiceSession) RemoveDir added in v0.5.0 

func (session *PoolServiceSession) RemoveDir(path string, recurse bool, force bool) error

RemoveDir removes iRODS collection

func (*PoolServiceSession) RemoveFile added in v0.5.0 

func (session *PoolServiceSession) RemoveFile(path string, force bool) error

RemoveFile removes iRODS data object

func (*PoolServiceSession) RemoveXattr added in v0.6.0 

func (session *PoolServiceSession) RemoveXattr(path string, name string) error

RemoveXattr removes iRODS metadata (xattr)

func (*PoolServiceSession) RenameDirToDir added in v0.5.0 

func (session *PoolServiceSession) RenameDirToDir(srcPath string, destPath string) error

RenameDirToDir renames iRODS collection

func (*PoolServiceSession) RenameFileToFile added in v0.5.0 

func (session *PoolServiceSession) RenameFileToFile(srcPath string, destPath string) error

RenameFileToFile renames iRODS data object

func (*PoolServiceSession) SetXattr added in v0.6.0 

func (session *PoolServiceSession) SetXattr(path string, name string, value string) error

SetXattr sets iRODS metadata (xattr)

func (*PoolServiceSession) Stat added in v0.5.0 

func (session *PoolServiceSession) Stat(path string) (*irodsclient_fs.Entry, error)

Stat stats iRODS entry

func (*PoolServiceSession) TruncateFile added in v0.5.0 

func (session *PoolServiceSession) TruncateFile(path string, size int64) error

TruncateFile truncates iRODS data object

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.