Documentation
¶
Index ¶
- Variables
- type Client
- func (o *Client) DeleteChunk(ctx context.Context, userID, chunkID string) error
- func (o *Client) GetChunks(ctx context.Context, chunks []chunk.Chunk) ([]chunk.Chunk, error)
- func (o *Client) IsChunkNotFoundErr(err error) bool
- func (o *Client) PutChunks(ctx context.Context, chunks []chunk.Chunk) error
- func (o *Client) Stop()
- type KeyEncoder
Constants ¶
This section is empty.
Variables ¶
View Source
var FSEncoder = func(schema chunk.SchemaConfig, chk chunk.Chunk) string { key := schema.ExternalKey(chk) if schema.VersionForChunk(chk) > 11 { split := strings.LastIndexByte(key, '/') encodedTail := base64Encoder(key[split+1:]) return strings.Join([]string{key[:split], encodedTail}, "/") } return base64Encoder(key) }
Functions ¶
This section is empty.
Types ¶
type Client ¶
type Client struct {
// contains filtered or unexported fields
}
Client is used to store chunks in object store backends
func NewClient ¶
func NewClient(store chunk.ObjectClient, encoder KeyEncoder, schema chunk.SchemaConfig) *Client
NewClient wraps the provided ObjectClient with a chunk.Client implementation
func NewClientWithMaxParallel ¶
func NewClientWithMaxParallel(store chunk.ObjectClient, encoder KeyEncoder, maxParallel int, schema chunk.SchemaConfig) *Client
func (*Client) DeleteChunk ¶
GetChunks retrieves the specified chunks from the configured backend
func (*Client) IsChunkNotFoundErr ¶
type KeyEncoder ¶
type KeyEncoder func(schema chunk.SchemaConfig, chk chunk.Chunk) string
KeyEncoder is used to encode chunk keys before writing/retrieving chunks from the underlying ObjectClient Schema/Chunk are passed as arguments to allow this to improve over revisions
Source Files
Click to show internal directories.
Click to hide internal directories.