service

package
v0.2.4 Latest Latest
Warning

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

 Go to latest Published: Jan 27, 2022 License: BSD-3-Clause Imports: 20 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type FileHandle 

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

func NewFileHandle added in v0.1.3 

func NewFileHandle(handleID string, sessionID string, connectionID string, writer io.Writer, reader io.Reader, fileHandle *irodsclient_fs.FileHandle, mutex *sync.Mutex) *FileHandle

func (*FileHandle) Flush added in v0.1.3 

func (handle *FileHandle) Flush() error

func (*FileHandle) GetEntryPath added in v0.1.3 

func (handle *FileHandle) GetEntryPath() string

func (*FileHandle) GetFileOpenMode added in v0.1.3 

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

func (*FileHandle) GetID added in v0.1.3 

func (handle *FileHandle) GetID() string

func (*FileHandle) GetOffset added in v0.1.3 

func (handle *FileHandle) GetOffset() int64

func (*FileHandle) ReadAt added in v0.1.3 

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

func (*FileHandle) Release added in v0.1.3 

func (handle *FileHandle) Release() error

func (*FileHandle) WriteAt added in v0.1.3 

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

type IRODSConnection added in v0.1.3 

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

IRODSConnection is a struct for iRODS Connection

func NewIRODSConnection added in v0.1.3 

func NewIRODSConnection(connectionID string, account *api.Account, applicationName string, cacheTimeoutSettings []commons.MetadataCacheTimeoutSetting) (*IRODSConnection, error)

func (*IRODSConnection) AddSession added in v0.1.3 

func (connection *IRODSConnection) AddSession(sessionID string)

func (*IRODSConnection) GetID added in v0.1.3 

func (connection *IRODSConnection) GetID() string

func (*IRODSConnection) GetIRODSFS added in v0.1.3 

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

func (*IRODSConnection) GetSessions added in v0.1.3 

func (connection *IRODSConnection) GetSessions() int

func (*IRODSConnection) Release added in v0.1.3 

func (connection *IRODSConnection) Release()

func (*IRODSConnection) ReleaseIfNoSession added in v0.1.3 

func (connection *IRODSConnection) ReleaseIfNoSession() bool

func (*IRODSConnection) RemoveSession added in v0.1.3 

func (connection *IRODSConnection) RemoveSession(sessionID string)

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

func (svc *PoolService) Destroy()

Destroy destroys the service

func (*PoolService) Init 

func (svc *PoolService) Init() error

Init initializes the service

func (*PoolService) Start 

func (svc *PoolService) Start() error

Start starts 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 Server 

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

Server is a struct for Server

func NewServer 

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

func (*Server) Close 

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

func (*Server) CreateFile 

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

func (*Server) ExistsDir 

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

func (*Server) ExistsFile 

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

func (*Server) Flush 

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

func (*Server) GetIRODSConnections added in v0.1.3 

func (server *Server) GetIRODSConnections() int

func (*Server) GetIRODSFSCount added in v0.1.3 

func (server *Server) GetIRODSFSCount() int

func (*Server) GetOffset 

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

func (*Server) GetSessions added in v0.1.3 

func (server *Server) GetSessions() int

func (*Server) List 

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

func (*Server) ListDirACLs added in v0.1.9 

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

func (*Server) ListFileACLs added in v0.1.9 

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

func (*Server) ListUserGroups added in v0.1.9 

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

func (*Server) Login 

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

func (*Server) Logout 

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

func (*Server) LogoutAll 

func (server *Server) LogoutAll()

func (*Server) MakeDir 

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

func (*Server) OpenFile 

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

func (*Server) ReadAt 

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

func (*Server) Release 

func (server *Server) Release()

func (*Server) RemoveDir 

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

func (*Server) RemoveFile 

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

func (*Server) RenameDirToDir 

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

func (*Server) RenameFileToFile 

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

func (*Server) Stat 

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

func (*Server) TruncateFile 

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

func (*Server) WriteAt 

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

type ServerConfig 

type ServerConfig struct {
	BufferSizeMax        int64
	CacheSizeMax         int64
	CacheRootPath        string
	CacheTimeoutSettings []commons.MetadataCacheTimeoutSetting
}

ServerConfig is a configuration for Server

type Session 

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

Session is a struct for client login

func NewSession added in v0.1.3 

func NewSession(clientID string, connectionID string) *Session

func (*Session) AddFileHandle added in v0.1.3 

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

func (*Session) GetClientID added in v0.1.3 

func (session *Session) GetClientID() string

func (*Session) GetConnectionID added in v0.1.3 

func (session *Session) GetConnectionID() string

func (*Session) GetFileHandle added in v0.1.3 

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

func (*Session) GetID added in v0.1.3 

func (session *Session) GetID() string

func (*Session) Release added in v0.1.3 

func (session *Session) Release()

func (*Session) RemoveFileHandle added in v0.1.3 

func (session *Session) RemoveFileHandle(fileHandleID string)

func (*Session) UpdateLastAccessTime added in v0.1.3 

func (session *Session) UpdateLastAccessTime()

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.