upload

Documentation

Index

• func NewChunkServer(logger *slog.Logger, fsys, cacheFS writablefs.FS) (string, http.Handler)
• func NewServer(logger *slog.Logger, fsys, cacheFS writablefs.FS) (string, http.Handler)
• type ChunkServer
• type Client
  • func NewClient(logger *slog.Logger, baseURL string, opts *ClientOptions) (*Client, error)
  • func (c *Client) Upload(ctx context.Context, path string, r io.ReaderAt, size int64) error
• type ClientOptions
• type Server
  • func (s *Server) Abort(ctx context.Context, req *connect.Request[wrapperspb.StringValue]) (*connect.Response[emptypb.Empty], error)
  • func (s *Server) Complete(ctx context.Context, req *connect.Request[wrapperspb.StringValue]) (*connect.Response[emptypb.Empty], error)
  • func (s *Server) New(ctx context.Context, req *connect.Request[v1alpha1.NewRequest]) (*connect.Response[wrapperspb.StringValue], error)
  • func (s *Server) PollForCompletion(ctx context.Context, req *connect.Request[wrapperspb.StringValue]) (*connect.Response[v1alpha1.CompleteResponse], error)

Functions

func NewChunkServer

func NewChunkServer(logger *slog.Logger, fsys, cacheFS writablefs.FS) (string, http.Handler)

func NewServer

func NewServer(logger *slog.Logger, fsys, cacheFS writablefs.FS) (string, http.Handler)

Types

type ChunkServer

type ChunkServer struct {
	http.Handler
	// contains filtered or unexported fields
}

type Client

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

func NewClient

func NewClient(logger *slog.Logger, baseURL string, opts *ClientOptions) (*Client, error)

func (*Client) Upload

func (c *Client) Upload(ctx context.Context, path string, r io.ReaderAt, size int64) error

Upload uploads a file to the server, you must provide a ReaderAt so that chunks can be read concurrently.

type ClientOptions

type ClientOptions struct {
	// NumConnections is the number of concurrent connections to use when uploading chunks.
	NumConnections int
	// ChunkSizeBytes is the size of each chunk.
	ChunkSizeBytes int64
	// MaxRetryAttempts is the maximum number of retry attempts to make before giving up.
	MaxRetryAttempts int
	// TLSClientConfig is the optional TLS configuration to use when making requests.
	TLSClientConfig *tls.Config
}

ClientOptions are options for configuring the behavior of the upload client.

type Server

type Server struct {
	http.Handler
	// contains filtered or unexported fields
}

func (*Server) Abort

func (s *Server) Abort(ctx context.Context, req *connect.Request[wrapperspb.StringValue]) (*connect.Response[emptypb.Empty], error)

func (*Server) Complete

func (s *Server) Complete(ctx context.Context, req *connect.Request[wrapperspb.StringValue]) (*connect.Response[emptypb.Empty], error)

func (*Server) New

func (s *Server) New(ctx context.Context, req *connect.Request[v1alpha1.NewRequest]) (*connect.Response[wrapperspb.StringValue], error)

func (*Server) PollForCompletion

func (s *Server) PollForCompletion(ctx context.Context, req *connect.Request[wrapperspb.StringValue]) (*connect.Response[v1alpha1.CompleteResponse], error)