consumertest

Documentation

Index

• type Shard
  • func NewShard(prefix string) (*Shard, error)
  • func (s *Shard) Cache() interface{}
  • func (s *Shard) Close() error
  • func (s *Shard) Database() *rocks.DB
  • func (s *Shard) DatabaseContent() map[string]string
  • func (s *Shard) FlushTransaction() error
  • func (s *Shard) ID() consumer.ShardID
  • func (s *Shard) Partition() topic.Partition
  • func (s *Shard) ReadOptions() *rocks.ReadOptions
  • func (s *Shard) SetCache(c interface{})
  • func (s *Shard) Transaction() *rocks.WriteBatch
  • func (s *Shard) WriteOptions() *rocks.WriteOptions

Types

type Shard

type Shard struct {
	IDFixture        consumer.ShardID
	PartitionFixture topic.Partition
	// contains filtered or unexported fields
}

Test type which conforms to consumer.Shard, and manages setup & teardown of a test RocksDB instance.

func NewShard

func NewShard(prefix string) (*Shard, error)

Initializes a Shard & database backed by a temporary directory. TODO(johnny): Since this is test support, panic on error (rather than returning it).

func (*Shard) Cache

func (s *Shard) Cache() interface{}

func (*Shard) Close

func (s *Shard) Close() error

Closes and removes the Shard database.

func (*Shard) Database

func (s *Shard) Database() *rocks.DB

func (*Shard) DatabaseContent

func (s *Shard) DatabaseContent() map[string]string

DatabaseContents enumerates and returns keys and values from the database as a map. As this is a test support method, it panics on iterator error.

func (*Shard) FlushTransaction

func (s *Shard) FlushTransaction() error

Flushes the current Shard transaction WriteBatch to the database.

func (*Shard) ID

func (s *Shard) ID() consumer.ShardID

consumer.Shard implementation.

func (*Shard) Partition

func (s *Shard) Partition() topic.Partition

func (*Shard) ReadOptions

func (s *Shard) ReadOptions() *rocks.ReadOptions

func (*Shard) SetCache

func (s *Shard) SetCache(c interface{})

func (*Shard) Transaction

func (s *Shard) Transaction() *rocks.WriteBatch

func (*Shard) WriteOptions

func (s *Shard) WriteOptions() *rocks.WriteOptions