server

Documentation

Index

• Constants
• func ConvertTimestamp(t int64) (out *timestamppb.Timestamp)
• type FileServer
  • func (fs *FileServer) CleanTombstones(ctx context.Context, _ *fileserver.CleanTombstonesRequest) (*fileserver.CleanTombstonesResponse, error)
  • func (fs *FileServer) DeleteFile(ctx context.Context, req *fileserver.DeleteFileRequest) (*fileserver.DeleteFileResponse, error)
  • func (fs *FileServer) DownloadFile(req *fileserver.DownloadFileRequest, ...) error
  • func (fs *FileServer) GetFile(ctx context.Context, req *fileserver.GetFileRequest) (*fileserver.GetFileResponse, error)
  • func (fs *FileServer) ListFiles(ctx context.Context, req *fileserver.ListFilesRequest) (*fileserver.ListFilesResponse, error)
  • func (fs *FileServer) RegisterHTTPRoutes(mux *runtime.ServeMux) error
  • func (fs *FileServer) UpdateFileMetadata(ctx context.Context, req *fileserver.UpdateFileMetadataRequest) (*fileserver.UpdateFileMetadataResponse, error)
  • func (fs *FileServer) UploadFile(stream fileserver.FileServer_UploadFileServer) error
• type Server
  • func (frs *Server) Start(ctx context.Context) error

Constants

const (
	ErrFileChecksumIncorrect = errors.Sentinel("calculated checksum does not match")
	ErrFileInfoMissing       = errors.Sentinel("no file info provided")
	ErrFileContentMissing    = errors.Sentinel("no file data provided")
)

Functions

func ConvertTimestamp

func ConvertTimestamp(t int64) (out *timestamppb.Timestamp)

Types

type FileServer

type FileServer struct {
	*Server
	Health *health.Server
	fileserver.UnimplementedFileServerServer
}

func (*FileServer) CleanTombstones

func (fs *FileServer) CleanTombstones(ctx context.Context, _ *fileserver.CleanTombstonesRequest) (*fileserver.CleanTombstonesResponse, error)

func (*FileServer) DeleteFile

func (fs *FileServer) DeleteFile(ctx context.Context, req *fileserver.DeleteFileRequest) (*fileserver.DeleteFileResponse, error)

func (*FileServer) DownloadFile

func (fs *FileServer) DownloadFile(req *fileserver.DownloadFileRequest, stream fileserver.FileServer_DownloadFileServer) error

func (*FileServer) GetFile

func (fs *FileServer) GetFile(ctx context.Context, req *fileserver.GetFileRequest) (*fileserver.GetFileResponse, error)

func (*FileServer) ListFiles

func (fs *FileServer) ListFiles(ctx context.Context, req *fileserver.ListFilesRequest) (*fileserver.ListFilesResponse, error)

func (*FileServer) RegisterHTTPRoutes

func (fs *FileServer) RegisterHTTPRoutes(mux *runtime.ServeMux) error

func (*FileServer) UpdateFileMetadata

func (fs *FileServer) UpdateFileMetadata(
	ctx context.Context,
	req *fileserver.UpdateFileMetadataRequest,
) (*fileserver.UpdateFileMetadataResponse, error)

func (*FileServer) UploadFile

func (fs *FileServer) UploadFile(stream fileserver.FileServer_UploadFileServer) error

type Server

type Server struct {
	Log       logr.Logger
	FileStore database.StoredFileStore

	APIEndpoint     string
	GatewayEndpoint string

	Health                  *health.Server
	APIListenerProvider     func(addr string) (net.Listener, error)
	GatewayListenerProvider func(addr string) (net.Listener, error)
}

func (*Server) Start

func (frs *Server) Start(ctx context.Context) error