client

Documentation

Index

• type Client
  • func NewClient(target string, opts ...grpc.DialOption) (*Client, error)
  • func (c *Client) Archive(ctx context.Context, key string) (*pb.ArchiveReply, error)
  • func (c *Client) ArchiveInfo(ctx context.Context, key string) (*pb.ArchiveInfoReply, error)
  • func (c *Client) ArchiveStatus(ctx context.Context, key string) (*pb.ArchiveStatusReply, error)
  • func (c *Client) ArchiveWatch(ctx context.Context, key string, ch chan<- string) error
  • func (c *Client) Close() error
  • func (c *Client) Init(ctx context.Context, name string) (*pb.InitReply, error)
  • func (c *Client) Links(ctx context.Context, key string) (*pb.LinksReply, error)
  • func (c *Client) List(ctx context.Context) (*pb.ListReply, error)
  • func (c *Client) ListPath(ctx context.Context, key, pth string) (*pb.ListPathReply, error)
  • func (c *Client) PullPath(ctx context.Context, key, pth string, writer io.Writer, opts ...Option) error
  • func (c *Client) PushPath(ctx context.Context, key, pth string, reader io.Reader, opts ...Option) (result path.Resolved, root path.Resolved, err error)
  • func (c *Client) Remove(ctx context.Context, key string) error
  • func (c *Client) RemovePath(ctx context.Context, key, pth string, opts ...Option) (path.Resolved, error)
• type Option
  • func WithFastForwardOnly(root path.Resolved) Option
  • func WithProgress(ch chan<- int64) Option

Types

type Client

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

Client provides the client api.

func NewClient

func NewClient(target string, opts ...grpc.DialOption) (*Client, error)

NewClient starts the client.

func (*Client) Archive

func (c *Client) Archive(ctx context.Context, key string) (*pb.ArchiveReply, error)

func (*Client) ArchiveInfo

func (c *Client) ArchiveInfo(ctx context.Context, key string) (*pb.ArchiveInfoReply, error)

func (*Client) ArchiveStatus

func (c *Client) ArchiveStatus(ctx context.Context, key string) (*pb.ArchiveStatusReply, error)

func (*Client) ArchiveWatch

func (c *Client) ArchiveWatch(ctx context.Context, key string, ch chan<- string) error

func (*Client) Close

func (c *Client) Close() error

Close closes the client's grpc connection and cancels any active requests.

func (*Client) Init

func (c *Client) Init(ctx context.Context, name string) (*pb.InitReply, error)

Init initializes a new bucket. The bucket name is only meant to help identify a bucket in a UI and is not unique.

func (*Client) Links

func (c *Client) Links(ctx context.Context, key string) (*pb.LinksReply, error)

Links returns a list of links that can be used to view the bucket

func (*Client) List

func (c *Client) List(ctx context.Context) (*pb.ListReply, error)

List returns a list of all bucket roots.

func (*Client) ListPath

func (c *Client) ListPath(ctx context.Context, key, pth string) (*pb.ListPathReply, error)

ListPath returns information about a bucket path.

func (*Client) PullPath

func (c *Client) PullPath(ctx context.Context, key, pth string, writer io.Writer, opts ...Option) error

PullPath pulls the bucket path, writing it to writer if it's a file.

func (*Client) PushPath

func (c *Client) PushPath(ctx context.Context, key, pth string, reader io.Reader, opts ...Option) (result path.Resolved, root path.Resolved, err error)

PushPath pushes a file to a bucket path. This will return the resolved path and the bucket's new root path.

func (*Client) Remove

func (c *Client) Remove(ctx context.Context, key string) error

Remove removes an entire bucket. Files and directories will be unpinned.

func (*Client) RemovePath

func (c *Client) RemovePath(ctx context.Context, key, pth string, opts ...Option) (path.Resolved, error)

RemovePath removes the file or directory at path. Files and directories will be unpinned.

type Option

type Option func(*options)

func WithFastForwardOnly

func WithFastForwardOnly(root path.Resolved) Option

WithFastForwardOnly instructs the remote to reject non-fast-forward updates by comparing root with the remote.

func WithProgress

func WithProgress(ch chan<- int64) Option

WithProgress writes progress updates to the given channel.