yolo

Documentation

Index

• Variables
• func Dump(t *btree.BTree)
• func NewAdminStorage(ms storage.LogStorage) storage.AdminStorage
• func NewLogStorage(kafka sarama.Client, client gohbase.Client) storage.LogStorage
• type MockClient
  • func NewMockClient(zkquorum string, options ...gohbase.Option) MockClient
  • func (m MockClient) Append(a *hrpc.Mutate) (*hrpc.Result, error)
  • func (m MockClient) CheckAndPut(p *hrpc.Mutate, family string, qualifier string, expectedValue []byte) (bool, error)
  • func (m MockClient) Close()
  • func (m MockClient) Delete(d *hrpc.Mutate) (*hrpc.Result, error)
  • func (m MockClient) Get(g *hrpc.Get) (*hrpc.Result, error)
  • func (m MockClient) Increment(i *hrpc.Mutate) (int64, error)
  • func (m MockClient) Put(p *hrpc.Mutate) (*hrpc.Result, error)
  • func (m MockClient) Scan(s *hrpc.Scan) hrpc.Scanner

Variables

var (
	ErrDoesNotExist = errors.New("requested entry does not exist")
)

Functions

func Dump

func Dump(t *btree.BTree)

Dump ascends the tree, logging the items contained.

func NewAdminStorage

func NewAdminStorage(ms storage.LogStorage) storage.AdminStorage

NewAdminStorage returns a storage.AdminStorage implementation backed by commitTreeStorage.

func NewLogStorage

func NewLogStorage(kafka sarama.Client, client gohbase.Client) storage.LogStorage

NewLogStorage creates a commit log LogStorage instance.

Types

type MockClient

type MockClient struct {
	sync.RWMutex
	// contains filtered or unexported fields
}

mockClient implements gohbase.Client for testing

func NewMockClient

func NewMockClient(zkquorum string, options ...gohbase.Option) MockClient

func (MockClient) Append

func (m MockClient) Append(a *hrpc.Mutate) (*hrpc.Result, error)

func (MockClient) CheckAndPut

func (m MockClient) CheckAndPut(p *hrpc.Mutate, family string, qualifier string, expectedValue []byte) (bool, error)

func (MockClient) Close

func (m MockClient) Close()

func (MockClient) Delete

func (m MockClient) Delete(d *hrpc.Mutate) (*hrpc.Result, error)

func (MockClient) Get

func (m MockClient) Get(g *hrpc.Get) (*hrpc.Result, error)

func (MockClient) Increment

func (m MockClient) Increment(i *hrpc.Mutate) (int64, error)

func (MockClient) Put

func (m MockClient) Put(p *hrpc.Mutate) (*hrpc.Result, error)

func (MockClient) Scan

func (m MockClient) Scan(s *hrpc.Scan) hrpc.Scanner