util

Documentation

Index

• func NewPrefixedObjectClient(downstreamClient chunk.ObjectClient, prefix string) chunk.ObjectClient
• type PrefixedObjectClient
  • func (p PrefixedObjectClient) DeleteObject(ctx context.Context, objectKey string) error
  • func (p PrefixedObjectClient) GetObject(ctx context.Context, objectKey string) (io.ReadCloser, error)
  • func (p PrefixedObjectClient) List(ctx context.Context, prefix, delimeter string) ([]chunk.StorageObject, []chunk.StorageCommonPrefix, error)
  • func (p PrefixedObjectClient) PutObject(ctx context.Context, objectKey string, object io.ReadSeeker) error
  • func (p PrefixedObjectClient) Stop()

Functions

func NewPrefixedObjectClient

func NewPrefixedObjectClient(downstreamClient chunk.ObjectClient, prefix string) chunk.ObjectClient

Types

type PrefixedObjectClient

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

func (PrefixedObjectClient) DeleteObject

func (p PrefixedObjectClient) DeleteObject(ctx context.Context, objectKey string) error

func (PrefixedObjectClient) GetObject

func (p PrefixedObjectClient) GetObject(ctx context.Context, objectKey string) (io.ReadCloser, error)

func (PrefixedObjectClient) List

func (p PrefixedObjectClient) List(ctx context.Context, prefix, delimeter string) ([]chunk.StorageObject, []chunk.StorageCommonPrefix, error)

func (PrefixedObjectClient) PutObject

func (p PrefixedObjectClient) PutObject(ctx context.Context, objectKey string, object io.ReadSeeker) error

func (PrefixedObjectClient) Stop

func (p PrefixedObjectClient) Stop()