remote

Documentation

Index

• Constants
• type BucketRouter
  • func NewBucketRouter() *BucketRouter
  • func (b *BucketRouter) AddLocal(bu *bucketstore.Bucket)
  • func (b *BucketRouter) AddNode(names [][]byte, cli HttpClient)
  • func (b *BucketRouter) AddNode2(names []string, cli HttpClient)
  • func (b *BucketRouter) Handler(ctx *fasthttp.RequestCtx)
  • func (b *BucketRouter) Remove2(names []string)
• type BucketShare
  • func NewBucketShare(s bucketstore.BucketStore) *BucketShare
  • func (b *BucketShare) Handler(ctx *fasthttp.RequestCtx)
  • func (b *BucketShare) Refresher()
  • func (b *BucketShare) Wakeup()
• type Client
  • func NewClient(c HttpClient, uuid []byte) *Client
  • func (c *Client) Expire(expire time.Time) error
  • func (c *Client) FreeStorage() (int64, error)
  • func (c *Client) Get(id []byte, overv, head, body *bufferex.Binary) (ok bool, err error)
  • func (c *Client) Put(id, overv, head, body []byte, expire time.Time) error
• type HttpClient
• type MultiClient
  • func NewMultiClient(c HttpClient) *MultiClient
  • func (m *MultiClient) OverExpire(bucket []byte, expire time.Time) error
  • func (m *MultiClient) OverFreeStorage(bucket []byte) (int64, error)
  • func (m *MultiClient) OverGet(bucket []byte, id []byte, overv, head, body *bufferex.Binary) (ok bool, e error)
  • func (m *MultiClient) OverPut(bucket []byte, id, overv, head, body []byte, expire time.Time) error
  • func (m *MultiClient) Submit(id, overv, head, body []byte, expire time.Time) (bucket bufferex.Binary, err error)

Constants

const URLDate = "20060102150405"

Types

type BucketRouter

type BucketRouter struct {
	Dmd *degrader.DegraderMetadata
	// contains filtered or unexported fields
}

func NewBucketRouter

func NewBucketRouter() *BucketRouter

func (*BucketRouter) AddLocal

func (b *BucketRouter) AddLocal(bu *bucketstore.Bucket)

func (*BucketRouter) AddNode

func (b *BucketRouter) AddNode(names [][]byte, cli HttpClient)

func (*BucketRouter) AddNode2

func (b *BucketRouter) AddNode2(names []string, cli HttpClient)

func (*BucketRouter) Handler

func (b *BucketRouter) Handler(ctx *fasthttp.RequestCtx)

func (*BucketRouter) Remove2

func (b *BucketRouter) Remove2(names []string)

type BucketShare

type BucketShare struct {
	Store bucketstore.BucketStore
	// contains filtered or unexported fields
}

func NewBucketShare

func NewBucketShare(s bucketstore.BucketStore) *BucketShare

func (*BucketShare) Handler

func (b *BucketShare) Handler(ctx *fasthttp.RequestCtx)

func (*BucketShare) Refresher

func (b *BucketShare) Refresher()

func (*BucketShare) Wakeup

func (b *BucketShare) Wakeup()

type Client

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

func NewClient

func NewClient(c HttpClient, uuid []byte) *Client

func (*Client) Expire

func (c *Client) Expire(expire time.Time) error

func (*Client) FreeStorage

func (c *Client) FreeStorage() (int64, error)

func (*Client) Get

func (c *Client) Get(id []byte, overv, head, body *bufferex.Binary) (ok bool, err error)

func (*Client) Put

func (c *Client) Put(id, overv, head, body []byte, expire time.Time) error

type HttpClient

type HttpClient interface {
	DoDeadline(req *fasthttp.Request, resp *fasthttp.Response, deadline time.Time) error
}

type MultiClient

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

func NewMultiClient

func NewMultiClient(c HttpClient) *MultiClient

func (*MultiClient) OverExpire

func (m *MultiClient) OverExpire(bucket []byte, expire time.Time) error

func (*MultiClient) OverFreeStorage

func (m *MultiClient) OverFreeStorage(bucket []byte) (int64, error)

func (*MultiClient) OverGet

func (m *MultiClient) OverGet(bucket []byte, id []byte, overv, head, body *bufferex.Binary) (ok bool, e error)

func (*MultiClient) OverPut

func (m *MultiClient) OverPut(bucket []byte, id, overv, head, body []byte, expire time.Time) error

func (*MultiClient) Submit

func (m *MultiClient) Submit(id, overv, head, body []byte, expire time.Time) (bucket bufferex.Binary, err error)