zookeeper

Documentation

Overview

Package zookeeper is a generated GoMock package.

Index

• type Conn
• type MockConn
  • func NewMockConn(ctrl *gomock.Controller) *MockConn
  • func (m *MockConn) Create(path string, data []byte, flags int32, acl []zk.ACL) (string, error)
  • func (m *MockConn) Delete(path string, version int32) error
  • func (m *MockConn) EXPECT() *MockConnMockRecorder
  • func (m *MockConn) Get(path string) ([]byte, *zk.Stat, error)
  • func (m *MockConn) Multi(ops ...interface{}) ([]zk.MultiResponse, error)
  • func (m *MockConn) Set(path string, data []byte, version int32) (*zk.Stat, error)
• type MockConnMockRecorder
  • func (mr *MockConnMockRecorder) Create(path, data, flags, acl interface{}) *gomock.Call
  • func (mr *MockConnMockRecorder) Delete(path, version interface{}) *gomock.Call
  • func (mr *MockConnMockRecorder) Get(path interface{}) *gomock.Call
  • func (mr *MockConnMockRecorder) Multi(ops ...interface{}) *gomock.Call
  • func (mr *MockConnMockRecorder) Set(path, data, version interface{}) *gomock.Call
• type StateStore
  • func NewZookeeperStateStore(logger logger.Logger) *StateStore
  • func (s *StateStore) BulkDelete(reqs []state.DeleteRequest) error
  • func (s *StateStore) BulkGet(req []state.GetRequest) (bool, []state.BulkGetResponse, error)
  • func (s *StateStore) BulkSet(reqs []state.SetRequest) error
  • func (s *StateStore) Delete(req *state.DeleteRequest) error
  • func (s *StateStore) Get(req *state.GetRequest) (*state.GetResponse, error)
  • func (s *StateStore) Init(metadata state.Metadata) (err error)
  • func (s *StateStore) Set(req *state.SetRequest) error

Types

type Conn

type Conn interface {
	Create(path string, data []byte, flags int32, acl []zk.ACL) (string, error)

	Get(path string) ([]byte, *zk.Stat, error)

	Set(path string, data []byte, version int32) (*zk.Stat, error)

	Delete(path string, version int32) error

	Multi(ops ...interface{}) ([]zk.MultiResponse, error)
}

type MockConn

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

MockConn is a mock of Conn interface

func NewMockConn

func NewMockConn(ctrl *gomock.Controller) *MockConn

NewMockConn creates a new mock instance

func (*MockConn) Create

func (m *MockConn) Create(path string, data []byte, flags int32, acl []zk.ACL) (string, error)

Create mocks base method

func (*MockConn) Delete

func (m *MockConn) Delete(path string, version int32) error

Delete mocks base method

func (*MockConn) EXPECT

func (m *MockConn) EXPECT() *MockConnMockRecorder

EXPECT returns an object that allows the caller to indicate expected use

func (*MockConn) Get

func (m *MockConn) Get(path string) ([]byte, *zk.Stat, error)

Get mocks base method

func (*MockConn) Multi

func (m *MockConn) Multi(ops ...interface{}) ([]zk.MultiResponse, error)

Multi mocks base method

func (*MockConn) Set

func (m *MockConn) Set(path string, data []byte, version int32) (*zk.Stat, error)

Set mocks base method

type MockConnMockRecorder

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

MockConnMockRecorder is the mock recorder for MockConn

func (*MockConnMockRecorder) Create

func (mr *MockConnMockRecorder) Create(path, data, flags, acl interface{}) *gomock.Call

Create indicates an expected call of Create

func (*MockConnMockRecorder) Delete

func (mr *MockConnMockRecorder) Delete(path, version interface{}) *gomock.Call

Delete indicates an expected call of Delete

func (*MockConnMockRecorder) Get

func (mr *MockConnMockRecorder) Get(path interface{}) *gomock.Call

Get indicates an expected call of Get

func (*MockConnMockRecorder) Multi

func (mr *MockConnMockRecorder) Multi(ops ...interface{}) *gomock.Call

Multi indicates an expected call of Multi

func (*MockConnMockRecorder) Set

func (mr *MockConnMockRecorder) Set(path, data, version interface{}) *gomock.Call

Set indicates an expected call of Set

type StateStore

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

StateStore is a state store

func NewZookeeperStateStore

func NewZookeeperStateStore(logger logger.Logger) *StateStore

NewZookeeperStateStore returns a new Zookeeper state store

func (*StateStore) BulkDelete

func (s *StateStore) BulkDelete(reqs []state.DeleteRequest) error

BulkDelete performs a bulk delete operation

func (*StateStore) BulkGet

func (s *StateStore) BulkGet(req []state.GetRequest) (bool, []state.BulkGetResponse, error)

BulkGet performs a bulks get operations

func (*StateStore) BulkSet

func (s *StateStore) BulkSet(reqs []state.SetRequest) error

BulkSet performs a bulks save operation

func (*StateStore) Delete

func (s *StateStore) Delete(req *state.DeleteRequest) error

Delete performs a delete operation

func (*StateStore) Get

func (s *StateStore) Get(req *state.GetRequest) (*state.GetResponse, error)

Get retrieves state from Zookeeper with a key

func (*StateStore) Init

func (s *StateStore) Init(metadata state.Metadata) (err error)

func (*StateStore) Set

func (s *StateStore) Set(req *state.SetRequest) error

Set saves state into Zookeeper