service

package
v0.6.10 Latest Latest
Warning

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

 Go to latest Published: Mar 8, 2023 License: BSD-3-Clause Imports: 27 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func IsFileHandleNotFoundError added in v0.6.0 

func IsFileHandleNotFoundError(err error) bool

IsFileHandleNotFoundError evaluates if the given error is FileHandleNotFoundError

func IsIrodsFsClientInstanceNotFoundError added in v0.6.0 

func IsIrodsFsClientInstanceNotFoundError(err error) bool

IsIrodsFsClientInstanceNotFoundError evaluates if the given error is IrodsFsClientInstanceNotFoundError

func IsSessionNotFoundError added in v0.6.0 

func IsSessionNotFoundError(err error) bool

IsSessionNotFoundError evaluates if the given error is SessionNotFoundError

Types

type FileHandleNotFoundError added in v0.6.0 

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

FileHandleNotFoundError ...

func NewFileHandleNotFoundError added in v0.6.0 

func NewFileHandleNotFoundError(message string) *FileHandleNotFoundError

NewFileHandleNotFoundError creates FileHandleNotFoundError struct

func NewFileHandleNotFoundErrorf added in v0.6.0 

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

NewFileHandleNotFoundErrorf creates FileHandleNotFoundError struct

func (*FileHandleNotFoundError) Error added in v0.6.0 

func (e *FileHandleNotFoundError) Error() string

type IRODSFSClientInstance added in v0.5.0 

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

IRODSFSClientInstance is a struct for iRODS FS Client Instance

func (*IRODSFSClientInstance) GetFSClient added in v0.5.0 

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

func (*IRODSFSClientInstance) GetID added in v0.5.0 

func (instance *IRODSFSClientInstance) GetID() string

type IRODSFSClientInstanceManager added in v0.6.7 

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

IRODSFSClientInstanceManager manages IRODSFSClientInstance

func NewIRODSFSClientInstanceManager added in v0.6.7 

func NewIRODSFSClientInstanceManager(config *PoolServerConfig) *IRODSFSClientInstanceManager

func (*IRODSFSClientInstanceManager) AddPoolSession added in v0.6.7 

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

func (*IRODSFSClientInstanceManager) GetInstance added in v0.6.7 

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

func (*IRODSFSClientInstanceManager) GetInstances added in v0.6.7 

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

func (*IRODSFSClientInstanceManager) GetTotalConnections added in v0.6.7 

func (manager *IRODSFSClientInstanceManager) GetTotalConnections() int

func (*IRODSFSClientInstanceManager) GetTotalInstances added in v0.6.7 

func (manager *IRODSFSClientInstanceManager) GetTotalInstances() int

func (*IRODSFSClientInstanceManager) Release added in v0.6.7 

func (manager *IRODSFSClientInstanceManager) Release()

func (*IRODSFSClientInstanceManager) RemovePoolSession added in v0.6.7 

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

type IrodsFsClientInstanceNotFoundError added in v0.6.0 

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

IrodsFsClientInstanceNotFoundError ...

func NewIrodsFsClientInstanceNotFoundError added in v0.6.0 

func NewIrodsFsClientInstanceNotFoundError(message string) *IrodsFsClientInstanceNotFoundError

NewIrodsFsClientInstanceNotFoundError creates IrodsFsClientInstanceNotFoundError struct

func NewIrodsFsClientInstanceNotFoundErrorf added in v0.6.0 

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

NewIrodsFsClientInstanceNotFoundErrorf creates IrodsFsClientInstanceNotFoundError struct

func (*IrodsFsClientInstanceNotFoundError) Error added in v0.6.0 

func (e *IrodsFsClientInstanceNotFoundError) Error() string

type PoolFileHandle added in v0.5.0 

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

PoolFileHandle is a file handle managed by iRODSFS-Pool

func NewPoolFileHandle added in v0.5.0 

func NewPoolFileHandle(poolServer *PoolServer, poolSessionID string, irodsFsFileHandle irodsfs_common_irods.IRODSFSFileHandle, irodsFsFileHandlesForPrefetching []irodsfs_common_irods.IRODSFSFileHandle) (*PoolFileHandle, error)

NewPoolFileHandle creates a new pool file handle

func (*PoolFileHandle) AddEpectedFileHandlesForPrefetching added in v0.6.7 

func (handle *PoolFileHandle) AddEpectedFileHandlesForPrefetching(count int)

func (*PoolFileHandle) AddFileHandlesForPrefetching added in v0.5.4 

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

func (*PoolFileHandle) Flush added in v0.5.0 

func (handle *PoolFileHandle) Flush() error

func (*PoolFileHandle) GetAvailable added in v0.5.4 

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

func (*PoolFileHandle) GetEntryPath added in v0.5.0 

func (handle *PoolFileHandle) GetEntryPath() string

func (*PoolFileHandle) GetID added in v0.5.0 

func (handle *PoolFileHandle) GetID() string

func (*PoolFileHandle) GetOffset added in v0.5.0 

func (handle *PoolFileHandle) GetOffset() int64

func (*PoolFileHandle) GetOpenMode added in v0.5.0 

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

func (*PoolFileHandle) ReadAt added in v0.5.0 

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

func (*PoolFileHandle) Release added in v0.5.0 

func (handle *PoolFileHandle) Release() error

func (*PoolFileHandle) Truncate added in v0.5.0 

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

func (*PoolFileHandle) WriteAt added in v0.5.0 

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

type PoolServer added in v0.5.0 

type PoolServer struct {
	api.UnimplementedPoolAPIServer
	// contains filtered or unexported fields
}

PoolServer is a struct for PoolServer

func NewPoolServer added in v0.5.0 

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

func (*PoolServer) Close added in v0.5.0 

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

func (*PoolServer) CollectMetrics added in v0.5.12 

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

func (*PoolServer) CollectPrometheusMetrics added in v0.5.12 

func (server *PoolServer) CollectPrometheusMetrics()

func (*PoolServer) CreateFile added in v0.5.0 

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

func (*PoolServer) ExistsDir added in v0.5.0 

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

func (*PoolServer) ExistsFile added in v0.5.0 

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

func (*PoolServer) Flush added in v0.5.0 

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

func (*PoolServer) GetIRODSConnections added in v0.5.0 

func (server *PoolServer) GetIRODSConnections() int

func (*PoolServer) GetIRODSFSClientInstances added in v0.6.7 

func (server *PoolServer) GetIRODSFSClientInstances() int

func (*PoolServer) GetOffset added in v0.5.0 

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

func (*PoolServer) GetPoolSessions added in v0.5.0 

func (server *PoolServer) GetPoolSessions() int

func (*PoolServer) GetSessionManager added in v0.6.7 

func (server *PoolServer) GetSessionManager() *PoolSessionManager

func (*PoolServer) GetXattr added in v0.6.0 

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

func (*PoolServer) List added in v0.5.0 

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

func (*PoolServer) ListACLsForEntries added in v0.5.8 

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

func (*PoolServer) ListDirACLs added in v0.5.0 

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

func (*PoolServer) ListFileACLs added in v0.5.0 

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

func (*PoolServer) ListUserGroups added in v0.5.0 

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

func (*PoolServer) ListXattr added in v0.6.0 

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

func (*PoolServer) Login added in v0.5.0 

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

func (*PoolServer) Logout added in v0.5.0 

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

func (*PoolServer) LogoutAll added in v0.5.0 

func (server *PoolServer) LogoutAll()

func (*PoolServer) MakeDir added in v0.5.0 

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

func (*PoolServer) OpenFile added in v0.5.0 

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

func (*PoolServer) ReadAt added in v0.5.0 

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

func (*PoolServer) Release added in v0.5.0 

func (server *PoolServer) Release()

func (*PoolServer) RemoveDir added in v0.5.0 

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

func (*PoolServer) RemoveFile added in v0.5.0 

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

func (*PoolServer) RemoveXattr added in v0.6.0 

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

func (*PoolServer) RenameDirToDir added in v0.5.0 

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

func (*PoolServer) RenameFileToFile added in v0.5.0 

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

func (*PoolServer) SetXattr added in v0.6.0 

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

func (*PoolServer) Stat added in v0.5.0 

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

func (*PoolServer) SubscribeCacheEvents added in v0.6.7 

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

func (*PoolServer) Truncate added in v0.5.0 

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

func (*PoolServer) TruncateFile added in v0.5.0 

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

func (*PoolServer) UnsubscribeCacheEvents added in v0.6.7 

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

func (*PoolServer) WriteAt added in v0.5.0 

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

type PoolServerCacheEventSubscription added in v0.6.7 

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

type PoolServerConfig added in v0.5.0 

type PoolServerConfig struct {
	CacheSizeMax         int64
	CacheRootPath        string
	CacheTimeoutSettings []commons.MetadataCacheTimeoutSetting
	TempRootPath         string
}

PoolServerConfig is a configuration for Server

type PoolService 

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

PoolService is a service object

func NewPoolService 

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

NewPoolService creates a new pool service

func (*PoolService) Release added in v0.6.0 

func (svc *PoolService) Release()

Release releases the service

func (*PoolService) Start 

func (svc *PoolService) Start() error

Start starts the service

func (*PoolService) Stop added in v0.6.0 

func (svc *PoolService) Stop()

Stop stops the service

type PoolServiceStatHandler 

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

func (*PoolServiceStatHandler) HandleConn 

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

HandleConn processes the Conn stats.

func (*PoolServiceStatHandler) HandleRPC 

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

HandleRPC processes the RPC stats.

func (*PoolServiceStatHandler) TagConn 

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

func (*PoolServiceStatHandler) TagRPC 

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

type PoolSession added in v0.5.0 

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

PoolSession is a struct for client login

func (*PoolSession) AddPoolCacheEventHandler added in v0.6.7 

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

func (*PoolSession) AddPoolFileHandle added in v0.5.0 

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

func (*PoolSession) GetID added in v0.5.0 

func (session *PoolSession) GetID() string

func (*PoolSession) GetIRODSFSClientInstanceID added in v0.5.0 

func (session *PoolSession) GetIRODSFSClientInstanceID() string

func (*PoolSession) GetPoolCacheEventHandler added in v0.6.7 

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

func (*PoolSession) GetPoolClientID added in v0.5.0 

func (session *PoolSession) GetPoolClientID() string

func (*PoolSession) GetPoolFileHandle added in v0.5.0 

func (session *PoolSession) GetPoolFileHandle(poolFileHandleID string) (*PoolFileHandle, error)

func (*PoolSession) HandleCacheEvent added in v0.6.7 

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

func (*PoolSession) RemovePoolCacheEventHandler added in v0.6.7 

func (session *PoolSession) RemovePoolCacheEventHandler(handlerID string)

func (*PoolSession) RemovePoolFileHandle added in v0.5.0 

func (session *PoolSession) RemovePoolFileHandle(poolFileHandleID string)

func (*PoolSession) SetIRODSFSClientInstanceID added in v0.5.0 

func (session *PoolSession) SetIRODSFSClientInstanceID(irodsFsClientInstanceID string)

func (*PoolSession) UpdateLastAccessTime added in v0.5.0 

func (session *PoolSession) UpdateLastAccessTime()

type PoolSessionManager added in v0.6.7 

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

PoolSessionManager manages PoolSession

func NewPoolSessionManager added in v0.6.7 

func NewPoolSessionManager(config *PoolServerConfig) *PoolSessionManager

func (*PoolSessionManager) GetIRODSFSClientInstanceForSession added in v0.6.7 

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

func (*PoolSessionManager) GetIRODSFSClientInstances added in v0.6.7 

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

func (*PoolSessionManager) GetSession added in v0.6.7 

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

func (*PoolSessionManager) GetSessionAndIRODSFSClient added in v0.6.7 

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

func (*PoolSessionManager) GetSessionAndIRODSFSClientInstance added in v0.6.7 

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

func (*PoolSessionManager) GetSessions added in v0.6.7 

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

func (*PoolSessionManager) GetTotalIRODSFSClientConnections added in v0.6.7 

func (manager *PoolSessionManager) GetTotalIRODSFSClientConnections() int

func (*PoolSessionManager) GetTotalIRODSFSClientInstances added in v0.6.7 

func (manager *PoolSessionManager) GetTotalIRODSFSClientInstances() int

func (*PoolSessionManager) GetTotalSessions added in v0.6.7 

func (manager *PoolSessionManager) GetTotalSessions() int

func (*PoolSessionManager) NewSession added in v0.6.7 

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

func (*PoolSessionManager) Release added in v0.6.7 

func (manager *PoolSessionManager) Release()

func (*PoolSessionManager) ReleaseSession added in v0.6.7 

func (manager *PoolSessionManager) ReleaseSession(sessionID string)

type SessionNotFoundError added in v0.6.0 

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

SessionNotFoundError ...

func NewSessionNotFoundError added in v0.6.0 

func NewSessionNotFoundError(message string) *SessionNotFoundError

NewSessionNotFoundError creates SessionNotFoundError struct

func NewSessionNotFoundErrorf added in v0.6.0 

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

NewSessionNotFoundErrorf creates SessionNotFoundError struct

func (*SessionNotFoundError) Error added in v0.6.0 

func (e *SessionNotFoundError) Error() string

Source Files

View all Source files

Directories

Path Synopsis

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.