aerospike

Documentation

Index

• type ConfigStorage
  • func (s *ConfigStorage) DeleteRemote(name string) error
  • func (s *ConfigStorage) Remote(name string) (*config.RemoteConfig, error)
  • func (s *ConfigStorage) Remotes() ([]*config.RemoteConfig, error)
  • func (s *ConfigStorage) SetRemote(r *config.RemoteConfig) error
• type ObjectIter
  • func (i *ObjectIter) Close()
  • func (i *ObjectIter) ForEach(cb func(obj core.Object) error) error
  • func (i *ObjectIter) Next() (core.Object, error)
• type ObjectStorage
  • func (s *ObjectStorage) Begin() core.TxObjectStorage
  • func (s *ObjectStorage) Get(t core.ObjectType, h core.Hash) (core.Object, error)
  • func (s *ObjectStorage) Iter(t core.ObjectType) (core.ObjectIter, error)
  • func (s *ObjectStorage) NewObject() core.Object
  • func (s *ObjectStorage) Set(obj core.Object) (core.Hash, error)
  • func (s *ObjectStorage) Writer() (io.WriteCloser, error)
• type ReferenceStorage
  • func (s *ReferenceStorage) Get(n core.ReferenceName) (*core.Reference, error)
  • func (s *ReferenceStorage) Iter() (core.ReferenceIter, error)
  • func (s *ReferenceStorage) Set(ref *core.Reference) error
• type Storage
  • func NewStorage(client *driver.Client, ns, url string) (*Storage, error)
  • func (s *Storage) ConfigStorage() config.ConfigStorage
  • func (s *Storage) ObjectStorage() core.ObjectStorage
  • func (s *Storage) ReferenceStorage() core.ReferenceStorage
• type TxObjectStorage
  • func (tx *TxObjectStorage) Commit() error
  • func (tx *TxObjectStorage) Get(t core.ObjectType, h core.Hash) (core.Object, error)
  • func (tx *TxObjectStorage) Rollback() error
  • func (tx *TxObjectStorage) Set(obj core.Object) (core.Hash, error)

Types

type ConfigStorage

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

func (*ConfigStorage) DeleteRemote

func (s *ConfigStorage) DeleteRemote(name string) error

func (*ConfigStorage) Remote

func (s *ConfigStorage) Remote(name string) (*config.RemoteConfig, error)

func (*ConfigStorage) Remotes

func (s *ConfigStorage) Remotes() ([]*config.RemoteConfig, error)

func (*ConfigStorage) SetRemote

func (s *ConfigStorage) SetRemote(r *config.RemoteConfig) error

type ObjectIter

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

func (*ObjectIter) Close

func (i *ObjectIter) Close()

func (*ObjectIter) ForEach

func (i *ObjectIter) ForEach(cb func(obj core.Object) error) error

func (*ObjectIter) Next

func (i *ObjectIter) Next() (core.Object, error)

type ObjectStorage

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

func (*ObjectStorage) Begin

func (s *ObjectStorage) Begin() core.TxObjectStorage

func (*ObjectStorage) Get

func (s *ObjectStorage) Get(t core.ObjectType, h core.Hash) (core.Object, error)

func (*ObjectStorage) Iter

func (s *ObjectStorage) Iter(t core.ObjectType) (core.ObjectIter, error)

func (*ObjectStorage) NewObject

func (s *ObjectStorage) NewObject() core.Object

func (*ObjectStorage) Set

func (s *ObjectStorage) Set(obj core.Object) (core.Hash, error)

func (*ObjectStorage) Writer

func (s *ObjectStorage) Writer() (io.WriteCloser, error)

Writer method not supported, this method is optional to implemented.

type ReferenceStorage

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

func (*ReferenceStorage) Get

func (s *ReferenceStorage) Get(n core.ReferenceName) (*core.Reference, error)

Get returns a stored reference with the given name

func (*ReferenceStorage) Iter

func (s *ReferenceStorage) Iter() (core.ReferenceIter, error)

Iter returns a core.ReferenceIter

func (*ReferenceStorage) Set

func (s *ReferenceStorage) Set(ref *core.Reference) error

Set stores a reference.

type Storage

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

func NewStorage

func NewStorage(client *driver.Client, ns, url string) (*Storage, error)

func (*Storage) ConfigStorage

func (s *Storage) ConfigStorage() config.ConfigStorage

func (*Storage) ObjectStorage

func (s *Storage) ObjectStorage() core.ObjectStorage

func (*Storage) ReferenceStorage

func (s *Storage) ReferenceStorage() core.ReferenceStorage

type TxObjectStorage

type TxObjectStorage struct {
	Storage *ObjectStorage
}

func (*TxObjectStorage) Commit

func (tx *TxObjectStorage) Commit() error

func (*TxObjectStorage) Get

func (tx *TxObjectStorage) Get(t core.ObjectType, h core.Hash) (core.Object, error)

func (*TxObjectStorage) Rollback

func (tx *TxObjectStorage) Rollback() error

func (*TxObjectStorage) Set

func (tx *TxObjectStorage) Set(obj core.Object) (core.Hash, error)