blob

Documentation

Index

• type Client
  • func NewClient(cc grpc.ClientConnInterface) *Client
  • func (c *Client) AbandonSession(ctx context.Context, arg0 int64) error
  • func (c *Client) AcquireLease2(ctx context.Context, arg0 int64, arg1 int32) error
  • func (c *Client) AcquireLease2_2(ctx context.Context, arg0 int64, arg1 string) error
  • func (c *Client) AcquireLease3_1(ctx context.Context, arg0 int64, arg1 int32, arg2 int64) error
  • func (c *Client) AcquireLease3_3(ctx context.Context, arg0 int64, arg1 string, arg2 int64) error
  • func (c *Client) CreateSession(ctx context.Context, arg0 int64) (int64, error)
  • func (c *Client) GetLeasedBlobs(ctx context.Context) (int64, error)
  • func (c *Client) GetRemainingLeaseQuotaBytes(ctx context.Context) (int64, error)
  • func (c *Client) OpenBlob(ctx context.Context, arg0 int64) (int64, error)
  • func (c *Client) OpenSession(ctx context.Context, arg0 int64) (int64, error)
  • func (c *Client) ReleaseLease(ctx context.Context, arg0 int64) error

Types

type Client

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

Client wraps the gRPC StoreManagerService client.

func NewClient

func NewClient(cc grpc.ClientConnInterface) *Client

NewClient creates a new blob client.

func (*Client) AbandonSession

func (c *Client) AbandonSession(ctx context.Context, arg0 int64) error

AbandonSession calls the AbandonSession RPC.

func (*Client) AcquireLease2

func (c *Client) AcquireLease2(ctx context.Context, arg0 int64, arg1 int32) error

AcquireLease2 calls the AcquireLease2 RPC.

func (*Client) AcquireLease2_2

func (c *Client) AcquireLease2_2(ctx context.Context, arg0 int64, arg1 string) error

AcquireLease2_2 calls the AcquireLease2_2 RPC.

func (*Client) AcquireLease3_1

func (c *Client) AcquireLease3_1(ctx context.Context, arg0 int64, arg1 int32, arg2 int64) error

AcquireLease3_1 calls the AcquireLease3_1 RPC.

func (*Client) AcquireLease3_3

func (c *Client) AcquireLease3_3(ctx context.Context, arg0 int64, arg1 string, arg2 int64) error

AcquireLease3_3 calls the AcquireLease3_3 RPC.

func (*Client) CreateSession

func (c *Client) CreateSession(ctx context.Context, arg0 int64) (int64, error)

CreateSession calls the CreateSession RPC.

func (*Client) GetLeasedBlobs

func (c *Client) GetLeasedBlobs(ctx context.Context) (int64, error)

GetLeasedBlobs calls the GetLeasedBlobs RPC.

func (*Client) GetRemainingLeaseQuotaBytes

func (c *Client) GetRemainingLeaseQuotaBytes(ctx context.Context) (int64, error)

GetRemainingLeaseQuotaBytes calls the GetRemainingLeaseQuotaBytes RPC.

func (*Client) OpenBlob

func (c *Client) OpenBlob(ctx context.Context, arg0 int64) (int64, error)

OpenBlob calls the OpenBlob RPC.

func (*Client) OpenSession

func (c *Client) OpenSession(ctx context.Context, arg0 int64) (int64, error)

OpenSession calls the OpenSession RPC.

func (*Client) ReleaseLease

func (c *Client) ReleaseLease(ctx context.Context, arg0 int64) error

ReleaseLease calls the ReleaseLease RPC.