Documentation ¶
Index ¶
- Constants
- func GlobLiteralPrefix(glob string) string
- func ValidateFilename(p string) error
- type Env
- type Server
- func (s *Server) ComposeFileset(ctx context.Context, request *storage.ComposeFilesetRequest) (*storage.ComposeFilesetResponse, error)
- func (s *Server) CreateFileset(server storage.Fileset_CreateFilesetServer) error
- func (s *Server) ReadFileset(request *storage.ReadFilesetRequest, server storage.Fileset_ReadFilesetServer) error
- func (s *Server) RenewFileset(ctx context.Context, request *storage.RenewFilesetRequest) (*emptypb.Empty, error)
- func (s *Server) ShardFileset(ctx context.Context, request *storage.ShardFilesetRequest) (*storage.ShardFilesetResponse, error)
Constants ¶
View Source
const (
ChunkPrefix = "chunk/"
)
Variables ¶
This section is empty.
Functions ¶
func GlobLiteralPrefix ¶ added in v2.10.0
func ValidateFilename ¶ added in v2.10.0
Types ¶
type Env ¶
type Env struct { DB *pachsql.DB // ObjectStore is a client from the obj package ObjectStore obj.Client // Bucket is an object storage bucket from the Go CDK packages. // If set, it takes priority over ObjectStore Bucket *blob.Bucket Config pachconfig.StorageConfiguration }
type Server ¶
type Server struct { storage.UnimplementedFilesetServer Filesets *fileset.Storage Chunks *chunk.Storage Tracker track.Tracker }
Server contains the storage layer servers.
func (*Server) ComposeFileset ¶ added in v2.10.0
func (s *Server) ComposeFileset(ctx context.Context, request *storage.ComposeFilesetRequest) (*storage.ComposeFilesetResponse, error)
func (*Server) CreateFileset ¶ added in v2.10.0
func (s *Server) CreateFileset(server storage.Fileset_CreateFilesetServer) error
TODO: Copy file.
func (*Server) ReadFileset ¶ added in v2.10.0
func (s *Server) ReadFileset(request *storage.ReadFilesetRequest, server storage.Fileset_ReadFilesetServer) error
TODO: Add file filter error types.
func (*Server) RenewFileset ¶ added in v2.10.0
func (s *Server) RenewFileset(ctx context.Context, request *storage.RenewFilesetRequest) (*emptypb.Empty, error)
TODO: We should be able to use this and potentially others directly in PFS.
func (*Server) ShardFileset ¶ added in v2.10.0
func (s *Server) ShardFileset(ctx context.Context, request *storage.ShardFilesetRequest) (*storage.ShardFilesetResponse, error)
Directories ¶
Path | Synopsis |
---|---|
Package chunk provides access to data through content-addressed chunks.
|
Package chunk provides access to data through content-addressed chunks. |
Package fileset provides access to files through file sets.
|
Package fileset provides access to files through file sets. |
index
Package index provides access to files through multilevel indexes.
|
Package index provides access to files through multilevel indexes. |
Package kv provides a Key-Value Store interface and a few implementations.
|
Package kv provides a Key-Value Store interface and a few implementations. |
Click to show internal directories.
Click to hide internal directories.