grpc

Documentation

Index

• type ClientOpts
  • func WithLogger(l zerolog.Logger) ClientOpts
  • func WithProgressRender(b bool) ClientOpts
• type DownloaderClient
  • func NewDownloader(conn *grpc.ClientConn, opts ...ClientOpts) *DownloaderClient
  • func (c *DownloaderClient) Describe(ctx context.Context, digest string) (*materials.ResourceInfo, error)
  • func (c *DownloaderClient) Download(ctx context.Context, w io.Writer, digest string, totalBytes int64) error
• type UploaderClient
  • func NewUploader(conn *grpc.ClientConn, opts ...ClientOpts) *UploaderClient
  • func (c *UploaderClient) Upload(ctx context.Context, filepath string) (*materials.UpDownStatus, error)

Types

type ClientOpts

type ClientOpts func(u *casClient)

func WithLogger

func WithLogger(l zerolog.Logger) ClientOpts

func WithProgressRender

func WithProgressRender(b bool) ClientOpts

type DownloaderClient

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

func NewDownloader

func NewDownloader(conn *grpc.ClientConn, opts ...ClientOpts) *DownloaderClient

func (*DownloaderClient) Describe

func (c *DownloaderClient) Describe(ctx context.Context, digest string) (*materials.ResourceInfo, error)

Describe returns the metadata of a resource by its digest We use this to get the filename and the total size of the artifacct

func (*DownloaderClient) Download

func (c *DownloaderClient) Download(ctx context.Context, w io.Writer, digest string, totalBytes int64) error

Download downloads a file from the CAS and writes it to the provided writer It also receives a totalBytes parameter to render the progress bar

type UploaderClient

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

func NewUploader

func NewUploader(conn *grpc.ClientConn, opts ...ClientOpts) *UploaderClient

func (*UploaderClient) Upload

func (c *UploaderClient) Upload(ctx context.Context, filepath string) (*materials.UpDownStatus, error)

Uploads a given file to a CAS server