upload

Documentation

Index

• Variables
• type Server
  • func ProvideServer(blobs *blob.Store, cfg *config.Config, db *pgxpool.Pool, fs *fs.Store, ...) (*Server, error)
  • func (s *Server) Begin(ctx context.Context, req *upload.BeginRequest) (*upload.BeginResponse, error)
  • func (s *Server) Commit(ctx context.Context, req *upload.CommitRequest) (*upload.CommitResponse, error)
  • func (s *Server) Fetch(ctx context.Context, req *upload.FetchRequest) (*upload.FetchResponse, error)
  • func (s *Server) Transfer(ctx context.Context, req *upload.TransferRequest) (*upload.TransferResponse, error)

Variables

var Set = wire.NewSet(
	ProvideServer,
	wire.Bind(new(upload.UploadsServer), new(*Server)),
)

Set is used by wire.

Types

type Server

type Server struct {
	upload.UnsafeUploadsServer
	// contains filtered or unexported fields
}

Server implements the upload.UploadsServer API.

func ProvideServer

func ProvideServer(
	blobs *blob.Store,
	cfg *config.Config,
	db *pgxpool.Pool,
	fs *fs.Store,
	logger *log.Logger,
) (*Server, error)

ProvideServer is used by wire.

func (*Server) Begin

func (s *Server) Begin(ctx context.Context, req *upload.BeginRequest) (*upload.BeginResponse, error)

Begin implements upload.UploadsServer.

func (*Server) Commit

func (s *Server) Commit(ctx context.Context, req *upload.CommitRequest) (*upload.CommitResponse, error)

Commit implements upload.UploadsServer.

func (*Server) Fetch

func (s *Server) Fetch(ctx context.Context, req *upload.FetchRequest) (*upload.FetchResponse, error)

Fetch implements upload.UploadsServer.

func (*Server) Transfer

func (s *Server) Transfer(ctx context.Context, req *upload.TransferRequest) (*upload.TransferResponse, error)

Transfer implements upload.UploadsServer.