openstack

Documentation

Index

• type SwiftConfig
  • func (cfg *SwiftConfig) RegisterFlags(f *flag.FlagSet)
  • func (cfg *SwiftConfig) RegisterFlagsWithPrefix(prefix string, f *flag.FlagSet)
  • func (cfg *SwiftConfig) Validate() error
• type SwiftObjectClient
  • func NewSwiftObjectClient(cfg SwiftConfig, hedgingCfg hedging.Config) (*SwiftObjectClient, error)
  • func (s *SwiftObjectClient) DeleteObject(ctx context.Context, objectKey string) error
  • func (s *SwiftObjectClient) GetAttributes(ctx context.Context, objectKey string) (client.ObjectAttributes, error)
  • func (s *SwiftObjectClient) GetObject(ctx context.Context, objectKey string) (io.ReadCloser, int64, error)
  • func (s *SwiftObjectClient) GetObjectRange(ctx context.Context, objectKey string, offset, length int64) (io.ReadCloser, error)
  • func (s *SwiftObjectClient) IsObjectNotFoundErr(err error) bool
  • func (s *SwiftObjectClient) IsRetryableErr(error) bool
  • func (s *SwiftObjectClient) List(ctx context.Context, prefix, delimiter string) ([]client.StorageObject, []client.StorageCommonPrefix, error)
  • func (s *SwiftObjectClient) ObjectExists(ctx context.Context, objectKey string) (bool, error)
  • func (s *SwiftObjectClient) PutObject(ctx context.Context, objectKey string, object io.Reader) error
  • func (s *SwiftObjectClient) Stop()

Types

type SwiftConfig

type SwiftConfig struct {
	bucket_swift.Config `yaml:",inline"`
}

SwiftConfig is config for the Swift Chunk Client.

func (*SwiftConfig) RegisterFlags

func (cfg *SwiftConfig) RegisterFlags(f *flag.FlagSet)

RegisterFlags registers flags.

func (*SwiftConfig) RegisterFlagsWithPrefix

func (cfg *SwiftConfig) RegisterFlagsWithPrefix(prefix string, f *flag.FlagSet)

RegisterFlagsWithPrefix registers flags with prefix.

func (*SwiftConfig) Validate

func (cfg *SwiftConfig) Validate() error

Validate config and returns error on failure

type SwiftObjectClient

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

func NewSwiftObjectClient

func NewSwiftObjectClient(cfg SwiftConfig, hedgingCfg hedging.Config) (*SwiftObjectClient, error)

NewSwiftObjectClient makes a new chunk.Client that writes chunks to OpenStack Swift.

func (*SwiftObjectClient) DeleteObject

func (s *SwiftObjectClient) DeleteObject(ctx context.Context, objectKey string) error

DeleteObject deletes the specified object key from the configured Swift container.

func (*SwiftObjectClient) GetAttributes

func (s *SwiftObjectClient) GetAttributes(ctx context.Context, objectKey string) (client.ObjectAttributes, error)

func (*SwiftObjectClient) GetObject

func (s *SwiftObjectClient) GetObject(ctx context.Context, objectKey string) (io.ReadCloser, int64, error)

GetObject returns a reader and the size for the specified object key from the configured swift container.

func (*SwiftObjectClient) GetObjectRange

func (s *SwiftObjectClient) GetObjectRange(ctx context.Context, objectKey string, offset, length int64) (io.ReadCloser, error)

GetObject returns a reader and the size for the specified object key from the configured swift container.

func (*SwiftObjectClient) IsObjectNotFoundErr

func (s *SwiftObjectClient) IsObjectNotFoundErr(err error) bool

IsObjectNotFoundErr returns true if error means that object is not found. Relevant to GetObject and DeleteObject operations.

func (*SwiftObjectClient) IsRetryableErr

func (s *SwiftObjectClient) IsRetryableErr(error) bool

TODO(dannyk): implement for client

func (*SwiftObjectClient) List

func (s *SwiftObjectClient) List(ctx context.Context, prefix, delimiter string) ([]client.StorageObject, []client.StorageCommonPrefix, error)

List only objects from the store non-recursively

func (*SwiftObjectClient) ObjectExists

func (s *SwiftObjectClient) ObjectExists(ctx context.Context, objectKey string) (bool, error)

func (*SwiftObjectClient) PutObject

func (s *SwiftObjectClient) PutObject(ctx context.Context, objectKey string, object io.Reader) error

PutObject puts the specified bytes into the configured Swift container at the provided key

func (*SwiftObjectClient) Stop

func (s *SwiftObjectClient) Stop()