client

package
v0.5.12 Latest Latest
Warning

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

 Go to latest Published: Aug 31, 2022 License: BSD-3-Clause Imports: 15 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) 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) 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) 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) GetTransferMetrics added in v0.5.0 

func (session *PoolServiceSession) GetTransferMetrics() irodsclient_types.TransferMetrics

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) 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) 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) 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) 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.