swift

Documentation

Overview

Package swift implements common object storage abstractions against OpenStack swift APIs.

Index

• Constants
• func NewTestContainer(t testing.TB) (objstore.Bucket, func(), error)
• type Container
  • func NewContainer(logger log.Logger, conf []byte) (*Container, error)
  • func (c *Container) Attributes(ctx context.Context, name string) (objstore.ObjectAttributes, error)
  • func (*Container) Close() error
  • func (c *Container) Delete(ctx context.Context, name string) error
  • func (c *Container) Exists(ctx context.Context, name string) (bool, error)
  • func (c *Container) Get(ctx context.Context, name string) (io.ReadCloser, error)
  • func (c *Container) GetRange(ctx context.Context, name string, off, length int64) (io.ReadCloser, error)
  • func (c *Container) IsObjNotFoundErr(err error) bool
  • func (c *Container) Iter(ctx context.Context, dir string, f func(string) error) error
  • func (c *Container) Name() string
  • func (c *Container) Upload(ctx context.Context, name string, r io.Reader) error
• type SwiftConfig

Constants

const DirDelim = "/"

DirDelim is the delimiter used to model a directory structure in an object store bucket.

Functions

func NewTestContainer

func NewTestContainer(t testing.TB) (objstore.Bucket, func(), error)

NewTestContainer creates test objStore client that before returning creates temporary container. In a close function it empties and deletes the container.

Types

type Container

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

func NewContainer

func NewContainer(logger log.Logger, conf []byte) (*Container, error)

func (*Container) Attributes

func (c *Container) Attributes(ctx context.Context, name string) (objstore.ObjectAttributes, error)

Attributes returns information about the specified object.

func (*Container) Close

func (*Container) Close() error

func (*Container) Delete

func (c *Container) Delete(ctx context.Context, name string) error

Delete removes the object with the given name.

func (*Container) Exists

func (c *Container) Exists(ctx context.Context, name string) (bool, error)

Exists checks if the given object exists.

func (*Container) Get

func (c *Container) Get(ctx context.Context, name string) (io.ReadCloser, error)

Get returns a reader for the given object name.

func (*Container) GetRange

func (c *Container) GetRange(ctx context.Context, name string, off, length int64) (io.ReadCloser, error)

GetRange returns a new range reader for the given object name and range.

func (*Container) IsObjNotFoundErr

func (c *Container) IsObjNotFoundErr(err error) bool

IsObjNotFoundErr returns true if error means that object is not found. Relevant to Get operations.

func (*Container) Iter

func (c *Container) Iter(ctx context.Context, dir string, f func(string) error) error

Iter calls f for each entry in the given directory. The argument to f is the full object name including the prefix of the inspected directory.

func (*Container) Name

func (c *Container) Name() string

Name returns the container name for swift.

func (*Container) Upload

func (c *Container) Upload(ctx context.Context, name string, r io.Reader) error

Upload writes the contents of the reader as an object into the container.

type SwiftConfig

type SwiftConfig struct {
	AuthUrl           string `yaml:"auth_url"`
	Username          string `yaml:"username"`
	UserDomainName    string `yaml:"user_domain_name"`
	UserDomainID      string `yaml:"user_domain_id"`
	UserId            string `yaml:"user_id"`
	Password          string `yaml:"password"`
	DomainId          string `yaml:"domain_id"`
	DomainName        string `yaml:"domain_name"`
	ProjectID         string `yaml:"project_id"`
	ProjectName       string `yaml:"project_name"`
	ProjectDomainID   string `yaml:"project_domain_id"`
	ProjectDomainName string `yaml:"project_domain_name"`
	RegionName        string `yaml:"region_name"`
	ContainerName     string `yaml:"container_name"`
}