zookeeper

Documentation

Overview

Package zookeeper is a generated GoMock package.

Index

• func NewZookeeperStateStore(logger logger.Logger) state.Store
• 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 (s *StateStore) Delete(ctx context.Context, req *state.DeleteRequest) error
  • func (s *StateStore) Features() []state.Feature
  • func (s *StateStore) Get(ctx context.Context, req *state.GetRequest) (*state.GetResponse, error)
  • func (s *StateStore) GetComponentMetadata() map[string]string
  • func (s *StateStore) Init(_ context.Context, metadata state.Metadata) (err error)
  • func (s *StateStore) Set(ctx context.Context, req *state.SetRequest) error

Functions

func NewZookeeperStateStore

func NewZookeeperStateStore(logger logger.Logger) state.Store

NewZookeeperStateStore returns a new Zookeeper state store.

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 {
	state.BulkStore
	// contains filtered or unexported fields
}

StateStore is a state store.

func (*StateStore) Delete

func (s *StateStore) Delete(ctx context.Context, req *state.DeleteRequest) error

Delete performs a delete operation.

func (*StateStore) Features

func (s *StateStore) Features() []state.Feature

Features returns the features available in this state store.

func (*StateStore) Get

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

Get retrieves state from Zookeeper with a key.

func (*StateStore) GetComponentMetadata

func (s *StateStore) GetComponentMetadata() map[string]string

func (*StateStore) Init

func (s *StateStore) Init(_ context.Context, metadata state.Metadata) (err error)

func (*StateStore) Set

func (s *StateStore) Set(ctx context.Context, req *state.SetRequest) error

Set saves state into Zookeeper.