zookeeper

package
v1.9.0 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Oct 13, 2022 License: Apache-2.0 Imports: 13 Imported by: 3

Documentation

Overview

Package zookeeper is a generated GoMock package.

Index

Constants

This section is empty.

Variables

This section is empty.

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

StateStore is a state store.

func (*StateStore) BulkDelete

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

BulkDelete performs a bulk delete operation.

func (*StateStore) BulkGet added in v1.0.0

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) Features added in v1.1.1

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

Features returns the features available in this state store.

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.

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL