Documentation ¶
Index ¶
- Constants
- type BucketRouter
- type BucketShare
- type Client
- type HttpClient
- type 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 ¶
View Source
const URLDate = "20060102150405"
Variables ¶
This section is empty.
Functions ¶
This section is empty.
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 { // 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) FreeStorage ¶
type HttpClient ¶
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)
Click to show internal directories.
Click to hide internal directories.