service

package

Go to main page

Versions in this module

v0

v0.6.26

May 16, 2024

v0.6.25

Mar 27, 2024

v0.6.24

Mar 25, 2024

v0.6.23

Mar 22, 2024

v0.6.22

Nov 30, 2023

v0.6.21

Nov 29, 2023

v0.6.20

Nov 20, 2023

v0.6.19

Sep 25, 2023

v0.6.18

Sep 1, 2023

v0.6.17

Aug 28, 2023

v0.6.16

Aug 25, 2023

v0.6.15

Aug 22, 2023

v0.6.14

Jun 29, 2023

v0.6.13

Jun 23, 2023

v0.6.12

Mar 10, 2023

Changes in this version

type PoolFileHandle

+ func (handle *PoolFileHandle) AddExpectedFileHandlesForPrefetching(count int)

v0.6.11

Mar 10, 2023

Changes in this version

type PoolServer

+ func (server *PoolServer) PullCacheEvents(context context.Context, request *api.PullCacheEventsRequest) (*api.PullCacheEventsResponse, error)

v0.6.10

Mar 8, 2023

v0.6.9

Feb 27, 2023

v0.6.8

Feb 27, 2023

v0.6.7

Feb 27, 2023

Changes in this version

+ type IRODSFSClientInstanceManager struct

+ func NewIRODSFSClientInstanceManager(config *PoolServerConfig) *IRODSFSClientInstanceManager

+ func (manager *IRODSFSClientInstanceManager) AddPoolSession(account *api.Account, session *PoolSession, appName string) (string, error)

+ func (manager *IRODSFSClientInstanceManager) GetInstance(instanceID string) (*IRODSFSClientInstance, error)

+ func (manager *IRODSFSClientInstanceManager) GetInstances() []*IRODSFSClientInstance

+ func (manager *IRODSFSClientInstanceManager) GetTotalConnections() int

+ func (manager *IRODSFSClientInstanceManager) GetTotalInstances() int

+ func (manager *IRODSFSClientInstanceManager) Release()

+ func (manager *IRODSFSClientInstanceManager) RemovePoolSession(instanceID string, sessionID string)

type PoolFileHandle

+ func (handle *PoolFileHandle) AddEpectedFileHandlesForPrefetching(count int)

type PoolServer

+ func (server *PoolServer) GetIRODSFSClientInstances() int

+ func (server *PoolServer) GetSessionManager() *PoolSessionManager

+ func (server *PoolServer) SubscribeCacheEvents(request *api.SubscribeCacheEventsRequest, ...) error

+ func (server *PoolServer) UnsubscribeCacheEvents(context context.Context, request *api.UnsubscribeCacheEventsRequest) (*api.Empty, error)

+ type PoolServerCacheEventSubscription struct

type PoolSession

+ func (session *PoolSession) AddPoolCacheEventHandler(handler irodsclient_fs.FilesystemCacheEventHandler) string

+ func (session *PoolSession) GetPoolCacheEventHandler(handlerID string) (irodsclient_fs.FilesystemCacheEventHandler, error)

+ func (session *PoolSession) HandleCacheEvent(path string, eventType irodsclient_fs.FilesystemCacheEventType)

+ func (session *PoolSession) RemovePoolCacheEventHandler(handlerID string)

+ type PoolSessionManager struct

+ func NewPoolSessionManager(config *PoolServerConfig) *PoolSessionManager

+ func (manager *PoolSessionManager) GetIRODSFSClientInstanceForSession(sessionID string) (*IRODSFSClientInstance, error)

+ func (manager *PoolSessionManager) GetIRODSFSClientInstances() []*IRODSFSClientInstance

+ func (manager *PoolSessionManager) GetSession(sessionID string) (*PoolSession, error)

+ func (manager *PoolSessionManager) GetSessionAndIRODSFSClient(sessionID string) (*PoolSession, irodsfs_common_irods.IRODSFSClient, error)

+ func (manager *PoolSessionManager) GetSessionAndIRODSFSClientInstance(sessionID string) (*PoolSession, *IRODSFSClientInstance, error)

+ func (manager *PoolSessionManager) GetSessions() []*PoolSession

+ func (manager *PoolSessionManager) GetTotalIRODSFSClientConnections() int

+ func (manager *PoolSessionManager) GetTotalIRODSFSClientInstances() int

+ func (manager *PoolSessionManager) GetTotalSessions() int

+ func (manager *PoolSessionManager) NewSession(account *api.Account, clientID string, appName string) (*PoolSession, error)

+ func (manager *PoolSessionManager) Release()

+ func (manager *PoolSessionManager) ReleaseSession(sessionID string)

v0.6.5

Dec 15, 2022

v0.6.4

Dec 14, 2022

v0.6.3

Dec 9, 2022

v0.6.2

Dec 6, 2022

v0.6.1

Dec 5, 2022

v0.6.0

Nov 22, 2022

Changes in this version

+ func IsFileHandleNotFoundError(err error) bool

+ func IsIrodsFsClientInstanceNotFoundError(err error) bool

+ func IsSessionNotFoundError(err error) bool

+ type FileHandleNotFoundError struct

+ func NewFileHandleNotFoundError(message string) *FileHandleNotFoundError

+ func NewFileHandleNotFoundErrorf(format string, v ...interface{}) *FileHandleNotFoundError

+ func (e *FileHandleNotFoundError) Error() string

+ type IrodsFsClientInstanceNotFoundError struct

+ func NewIrodsFsClientInstanceNotFoundError(message string) *IrodsFsClientInstanceNotFoundError

+ func NewIrodsFsClientInstanceNotFoundErrorf(format string, v ...interface{}) *IrodsFsClientInstanceNotFoundError

+ func (e *IrodsFsClientInstanceNotFoundError) Error() string

type PoolServer

+ func (server *PoolServer) GetXattr(context context.Context, request *api.GetXattrRequest) (*api.GetXattrResponse, error)

+ func (server *PoolServer) ListXattr(context context.Context, request *api.ListXattrRequest) (*api.ListXattrResponse, error)

+ func (server *PoolServer) RemoveXattr(context context.Context, request *api.RemoveXattrRequest) (*api.Empty, error)

+ func (server *PoolServer) SetXattr(context context.Context, request *api.SetXattrRequest) (*api.Empty, error)

type PoolService

+ func (svc *PoolService) Release()

+ func (svc *PoolService) Stop()

+ type SessionNotFoundError struct

+ func NewSessionNotFoundError(message string) *SessionNotFoundError

+ func NewSessionNotFoundErrorf(format string, v ...interface{}) *SessionNotFoundError

+ func (e *SessionNotFoundError) Error() string

v0.5.15

Aug 31, 2022

v0.5.13

Aug 31, 2022

v0.5.12

Aug 31, 2022

Changes in this version

type PoolServer

+ func (server *PoolServer) CollectMetrics() irodsclient_metrics.IRODSMetrics

+ func (server *PoolServer) CollectPrometheusMetrics()

v0.5.11

Aug 13, 2022

v0.5.10

Jul 29, 2022

v0.5.9

Jul 29, 2022

v0.5.8

Jul 25, 2022

Changes in this version

type PoolServer

+ func (server *PoolServer) ListACLsForEntries(context context.Context, request *api.ListACLsForEntriesRequest) (*api.ListACLsForEntriesResponse, error)

v0.5.7

Jun 28, 2022

v0.5.6

Jun 27, 2022

v0.5.5

Jun 27, 2022

v0.5.4

Jun 25, 2022

Changes in this version

type PoolFileHandle

+ func (handle *PoolFileHandle) AddFileHandlesForPrefetching(irodsFsFileHandles []irodsfs_common_irods.IRODSFSFileHandle)

+ func (handle *PoolFileHandle) GetAvailable(offset int64) int64

v0.5.2

Jun 22, 2022

v0.5.1

Jun 6, 2022

v0.5.0

Jun 3, 2022

Changes in this version

+ func MakeIRODSFSClientInstanceID(account *api.Account) string

+ type IRODSFSClientInstance struct

+ func NewIRODSFSClientInstance(irodsFsClientInstanceID string, account *api.Account, applicationName string, ...) (*IRODSFSClientInstance, error)

+ func (instance *IRODSFSClientInstance) AddPoolSession(poolSession *PoolSession)

+ func (instance *IRODSFSClientInstance) GetFSClient() irodsfs_common_irods.IRODSFSClient

+ func (instance *IRODSFSClientInstance) GetID() string

+ func (instance *IRODSFSClientInstance) GetPoolSessions() int

+ func (instance *IRODSFSClientInstance) Release()

+ func (instance *IRODSFSClientInstance) ReleaseIfNoPoolSession() bool

+ func (instance *IRODSFSClientInstance) RemovePoolSession(poolSessionID string)

+ type PoolFileHandle struct

+ func NewPoolFileHandle(poolServer *PoolServer, poolSessionID string, irodsFsClientInstanceID string, ...) *PoolFileHandle

+ func (handle *PoolFileHandle) Flush() error

+ func (handle *PoolFileHandle) GetEntryPath() string

+ func (handle *PoolFileHandle) GetID() string

+ func (handle *PoolFileHandle) GetOffset() int64

+ func (handle *PoolFileHandle) GetOpenMode() irodsclient_types.FileOpenMode

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

+ func (handle *PoolFileHandle) Release() error

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

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

+ type PoolServer struct

+ func NewPoolServer(config *PoolServerConfig) (*PoolServer, error)

+ func (server *PoolServer) Close(context context.Context, request *api.CloseRequest) (*api.Empty, error)

+ func (server *PoolServer) CreateFile(context context.Context, request *api.CreateFileRequest) (*api.CreateFileResponse, error)

+ func (server *PoolServer) ExistsDir(context context.Context, request *api.ExistsDirRequest) (*api.ExistsDirResponse, error)

+ func (server *PoolServer) ExistsFile(context context.Context, request *api.ExistsFileRequest) (*api.ExistsFileResponse, error)

+ func (server *PoolServer) Flush(context context.Context, request *api.FlushRequest) (*api.Empty, error)

+ func (server *PoolServer) GetIRODSConnections() int

+ func (server *PoolServer) GetIRODSFSClientInstanceCount() int

+ func (server *PoolServer) GetOffset(context context.Context, request *api.GetOffsetRequest) (*api.GetOffsetResponse, error)

+ func (server *PoolServer) GetPoolSessions() int

+ func (server *PoolServer) List(context context.Context, request *api.ListRequest) (*api.ListResponse, error)

+ func (server *PoolServer) ListDirACLs(context context.Context, request *api.ListDirACLsRequest) (*api.ListDirACLsResponse, error)

+ func (server *PoolServer) ListFileACLs(context context.Context, request *api.ListFileACLsRequest) (*api.ListFileACLsResponse, error)

+ func (server *PoolServer) ListUserGroups(context context.Context, request *api.ListUserGroupsRequest) (*api.ListUserGroupsResponse, error)

+ func (server *PoolServer) Login(context context.Context, request *api.LoginRequest) (*api.LoginResponse, error)

+ func (server *PoolServer) Logout(context context.Context, request *api.LogoutRequest) (*api.Empty, error)

+ func (server *PoolServer) LogoutAll()

+ func (server *PoolServer) MakeDir(context context.Context, request *api.MakeDirRequest) (*api.Empty, error)

+ func (server *PoolServer) OpenFile(context context.Context, request *api.OpenFileRequest) (*api.OpenFileResponse, error)

+ func (server *PoolServer) ReadAt(context context.Context, request *api.ReadAtRequest) (*api.ReadAtResponse, error)

+ func (server *PoolServer) Release()

+ func (server *PoolServer) RemoveDir(context context.Context, request *api.RemoveDirRequest) (*api.Empty, error)

+ func (server *PoolServer) RemoveFile(context context.Context, request *api.RemoveFileRequest) (*api.Empty, error)

+ func (server *PoolServer) RenameDirToDir(context context.Context, request *api.RenameDirToDirRequest) (*api.Empty, error)

+ func (server *PoolServer) RenameFileToFile(context context.Context, request *api.RenameFileToFileRequest) (*api.Empty, error)

+ func (server *PoolServer) Stat(context context.Context, request *api.StatRequest) (*api.StatResponse, error)

+ func (server *PoolServer) Truncate(context context.Context, request *api.TruncateRequest) (*api.Empty, error)

+ func (server *PoolServer) TruncateFile(context context.Context, request *api.TruncateFileRequest) (*api.Empty, error)

+ func (server *PoolServer) WriteAt(context context.Context, request *api.WriteAtRequest) (*api.Empty, error)

+ type PoolServerConfig struct

+ CacheRootPath string

+ CacheSizeMax int64

+ CacheTimeoutSettings []commons.MetadataCacheTimeoutSetting

+ TempRootPath string

+ type PoolSession struct

+ func NewPoolSession(poolClientID string) *PoolSession

+ func (session *PoolSession) AddPoolFileHandle(poolFileHandle *PoolFileHandle)

+ func (session *PoolSession) GetID() string

+ func (session *PoolSession) GetIRODSFSClientInstanceID() string

+ func (session *PoolSession) GetPoolClientID() string

+ func (session *PoolSession) GetPoolFileHandle(poolFileHandleID string) *PoolFileHandle

+ func (session *PoolSession) Release()

+ func (session *PoolSession) RemovePoolFileHandle(poolFileHandleID string)

+ func (session *PoolSession) SetIRODSFSClientInstanceID(irodsFsClientInstanceID string)

+ func (session *PoolSession) UpdateLastAccessTime()

v0.4.0

Mar 28, 2022

v0.3.5

Mar 16, 2022

v0.3.4

Mar 9, 2022

v0.3.3

Mar 9, 2022

v0.3.2

Mar 5, 2022

v0.3.1

Feb 26, 2022

v0.3.0

Feb 25, 2022

v0.2.4

Jan 27, 2022

v0.2.3

Jan 25, 2022

v0.2.2

Jan 25, 2022

v0.2.1

Jan 25, 2022

Changes in this version

type ServerConfig

+ CacheTimeoutSettings []commons.MetadataCacheTimeoutSetting

v0.2.0

Jan 24, 2022

v0.1.11

Dec 1, 2021

v0.1.10

Dec 1, 2021

v0.1.9

Nov 2, 2021

Changes in this version

type Server

+ func (server *Server) ListDirACLs(context context.Context, request *api.ListDirACLsRequest) (*api.ListDirACLsResponse, error)

+ func (server *Server) ListFileACLs(context context.Context, request *api.ListFileACLsRequest) (*api.ListFileACLsResponse, error)

+ func (server *Server) ListUserGroups(context context.Context, request *api.ListUserGroupsRequest) (*api.ListUserGroupsResponse, error)

v0.1.8

Oct 27, 2021

v0.1.7

Oct 26, 2021

v0.1.6

Oct 23, 2021

v0.1.5

Oct 14, 2021

v0.1.4

Oct 13, 2021

v0.1.3

Oct 11, 2021

Changes in this version

type FileHandle

+ func NewFileHandle(handleID string, sessionID string, connectionID string, writer io.Writer, ...) *FileHandle

+ func (handle *FileHandle) Flush() error

+ func (handle *FileHandle) GetEntryPath() string

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

+ func (handle *FileHandle) GetID() string

+ func (handle *FileHandle) GetOffset() int64

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

+ func (handle *FileHandle) Release() error

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

+ type IRODSConnection struct

+ func NewIRODSConnection(connectionID string, account *api.Account, applicationName string) (*IRODSConnection, error)

+ func (connection *IRODSConnection) AddSession(sessionID string)

+ func (connection *IRODSConnection) GetID() string

+ func (connection *IRODSConnection) GetIRODSFS() *irodsclient_fs.FileSystem

+ func (connection *IRODSConnection) GetSessions() int

+ func (connection *IRODSConnection) Release()

+ func (connection *IRODSConnection) ReleaseIfNoSession() bool

+ func (connection *IRODSConnection) RemoveSession(sessionID string)

type Server

+ func (server *Server) GetIRODSConnections() int

+ func (server *Server) GetIRODSFSCount() int

+ func (server *Server) GetSessions() int

type Session

+ func NewSession(clientID string, connectionID string) *Session

+ func (session *Session) AddFileHandle(fileHandle *FileHandle)

+ func (session *Session) GetClientID() string

+ func (session *Session) GetConnectionID() string

+ func (session *Session) GetFileHandle(fileHandleID string) *FileHandle

+ func (session *Session) GetID() string

+ func (session *Session) Release()

+ func (session *Session) RemoveFileHandle(fileHandleID string)

+ func (session *Session) UpdateLastAccessTime()

v0.1.2

Oct 6, 2021

v0.1.1

Oct 4, 2021

v0.1.0

Oct 1, 2021

Changes in this version

+ type FileHandle struct

+ ID string

+ IRODSHandle *irodsclient_fs.FileHandle

+ Mutex *sync.Mutex

+ Reader io.Reader

+ SessionID string

+ Writer io.Writer

+ type PoolService struct

+ APIServer *Server

+ Config *commons.Config

+ GrpcServer *grpc.Server

+ Mutex sync.Mutex

+ StatHandler *PoolServiceStatHandler

+ TerminateChan chan bool

+ Terminated bool

+ func NewPoolService(config *commons.Config) (*PoolService, error)

+ func (svc *PoolService) Destroy()

+ func (svc *PoolService) Init() error

+ func (svc *PoolService) Start() error

+ type PoolServiceStatHandler struct

+ APIServer *Server

+ LiveConnections int

+ Mutex sync.Mutex

+ func (handler *PoolServiceStatHandler) HandleConn(c context.Context, s stats.ConnStats)

+ func (handler *PoolServiceStatHandler) HandleRPC(context.Context, stats.RPCStats)

+ func (handler *PoolServiceStatHandler) TagConn(context.Context, *stats.ConnTagInfo) context.Context

+ func (handler *PoolServiceStatHandler) TagRPC(context.Context, *stats.RPCTagInfo) context.Context

+ type Server struct

+ Buffer io.Buffer

+ Cache io.Cache

+ Config *ServerConfig

+ Mutex sync.RWMutex

+ Sessions map[string]*Session

+ func NewServer(config *ServerConfig) (*Server, error)

+ func (server *Server) Close(context context.Context, request *api.CloseRequest) (*api.Empty, error)

+ func (server *Server) Connections() int

+ func (server *Server) CreateFile(context context.Context, request *api.CreateFileRequest) (*api.CreateFileResponse, error)

+ func (server *Server) ExistsDir(context context.Context, request *api.ExistsDirRequest) (*api.ExistsDirResponse, error)

+ func (server *Server) ExistsFile(context context.Context, request *api.ExistsFileRequest) (*api.ExistsFileResponse, error)

+ func (server *Server) Flush(context context.Context, request *api.FlushRequest) (*api.Empty, error)

+ func (server *Server) GetOffset(context context.Context, request *api.GetOffsetRequest) (*api.GetOffsetResponse, error)

+ func (server *Server) List(context context.Context, request *api.ListRequest) (*api.ListResponse, error)

+ func (server *Server) ListDirACLsWithGroupUsers(context context.Context, request *api.ListDirACLsWithGroupUsersRequest) (*api.ListDirACLsWithGroupUsersResponse, error)

+ func (server *Server) ListFileACLsWithGroupUsers(context context.Context, request *api.ListFileACLsWithGroupUsersRequest) (*api.ListFileACLsWithGroupUsersResponse, error)

+ func (server *Server) Login(context context.Context, request *api.LoginRequest) (*api.LoginResponse, error)

+ func (server *Server) Logout(context context.Context, request *api.LogoutRequest) (*api.Empty, error)

+ func (server *Server) LogoutAll()

+ func (server *Server) MakeDir(context context.Context, request *api.MakeDirRequest) (*api.Empty, error)

+ func (server *Server) OpenFile(context context.Context, request *api.OpenFileRequest) (*api.OpenFileResponse, error)

+ func (server *Server) ReadAt(context context.Context, request *api.ReadAtRequest) (*api.ReadAtResponse, error)

+ func (server *Server) Release()

+ func (server *Server) RemoveDir(context context.Context, request *api.RemoveDirRequest) (*api.Empty, error)

+ func (server *Server) RemoveFile(context context.Context, request *api.RemoveFileRequest) (*api.Empty, error)

+ func (server *Server) RenameDirToDir(context context.Context, request *api.RenameDirToDirRequest) (*api.Empty, error)

+ func (server *Server) RenameFileToFile(context context.Context, request *api.RenameFileToFileRequest) (*api.Empty, error)

+ func (server *Server) Stat(context context.Context, request *api.StatRequest) (*api.StatResponse, error)

+ func (server *Server) TruncateFile(context context.Context, request *api.TruncateFileRequest) (*api.Empty, error)

+ func (server *Server) WriteAt(context context.Context, request *api.WriteAtRequest) (*api.Empty, error)

+ type ServerConfig struct

+ BufferSizeMax int64

+ CacheCleanup time.Duration

+ CacheRootPath string

+ CacheSizeMax int64

+ CacheTimeout time.Duration

+ type Session struct

+ Account *irodsclient_types.IRODSAccount

+ FileHandles map[string]*FileHandle

+ ID string

+ IRODSFS *irodsclient_fs.FileSystem

+ LastActivityTime time.Time

+ Mutex sync.Mutex

+ ReferenceCount int

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL