service

package
v0.8.3 Latest Latest
Warning

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

 Go to latest Published: Jan 8, 2025 License: BSD-3-Clause Imports: 28 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

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 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) AddExpectedFileHandlesForPrefetching added in v0.6.12 

func (handle *PoolFileHandle) AddExpectedFileHandlesForPrefetching(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) PullCacheEvents added in v0.6.11 

func (server *PoolServer) PullCacheEvents(context context.Context, request *api.PullCacheEventsRequest) (*api.PullCacheEventsResponse, 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(context context.Context, request *api.SubscribeCacheEventsRequest) (*api.Empty, 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 []irodsclient_fs.MetadataCacheTimeoutSetting
}

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)

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.