store

package

v0.0.0-...-79ca53b Latest Latest Go to latest Published: Apr 9, 2023 License: Apache-2.0 Imports: 9 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/nireo/rq

Links

Open Source Insights

Documentation ¶

Overview ¶

Package store is a generated GoMock package.

Index ¶

Variables
type MockStore
- func NewMockStore(ctrl *gomock.Controller) *MockStore
type MockStoreMockRecorder
type MockleveldbCommon
- func NewMockleveldbCommon(ctrl *gomock.Controller) *MockleveldbCommon
type MockleveldbCommonMockRecorder
type Store
- func NewStore(path string) (Store, error)
type Value
- func Decode(buf []byte) *Value
- func NewValue(data []byte) *Value
- func (v *Value) Encode() []byte

Constants ¶

This section is empty.

Variables ¶

View Source

var (
	ErrKeyDoesntExist = errors.New("key doesn't exist")
)

Functions ¶

This section is empty.

Types ¶

type MockStore ¶

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

MockStore is a mock of Store interface.

func NewMockStore ¶

func NewMockStore(ctrl *gomock.Controller) *MockStore

NewMockStore creates a new mock instance.

func (*MockStore) Ack ¶

func (m *MockStore) Ack(topic []byte, offset uint64) error

Ack mocks base method.

func (*MockStore) Close ¶

func (m *MockStore) Close() error

Close mocks base method.

func (*MockStore) EXPECT ¶

func (m *MockStore) EXPECT() *MockStoreMockRecorder

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

func (*MockStore) GetNext ¶

func (m *MockStore) GetNext(topic []byte) (*Value, uint64, error)

GetNext mocks base method.

func (*MockStore) Insert ¶

func (m *MockStore) Insert(topic []byte, val *Value) error

Insert mocks base method.

func (*MockStore) Nack ¶

func (m *MockStore) Nack(topic []byte, offset uint64) error

Nack mocks base method.

type MockStoreMockRecorder ¶

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

MockStoreMockRecorder is the mock recorder for MockStore.

func (*MockStoreMockRecorder) Ack ¶

func (mr *MockStoreMockRecorder) Ack(topic, offset interface{}) *gomock.Call

Ack indicates an expected call of Ack.

func (*MockStoreMockRecorder) Close ¶

func (mr *MockStoreMockRecorder) Close() *gomock.Call

Close indicates an expected call of Close.

func (*MockStoreMockRecorder) GetNext ¶

func (mr *MockStoreMockRecorder) GetNext(topic interface{}) *gomock.Call

GetNext indicates an expected call of GetNext.

func (*MockStoreMockRecorder) Insert ¶

func (mr *MockStoreMockRecorder) Insert(topic, val interface{}) *gomock.Call

Insert indicates an expected call of Insert.

func (*MockStoreMockRecorder) Nack ¶

func (mr *MockStoreMockRecorder) Nack(topic, offset interface{}) *gomock.Call

Nack indicates an expected call of Nack.

type MockleveldbCommon ¶

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

MockleveldbCommon is a mock of leveldbCommon interface.

func NewMockleveldbCommon ¶

func NewMockleveldbCommon(ctrl *gomock.Controller) *MockleveldbCommon

NewMockleveldbCommon creates a new mock instance.

func (*MockleveldbCommon) EXPECT ¶

func (m *MockleveldbCommon) EXPECT() *MockleveldbCommonMockRecorder

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

func (*MockleveldbCommon) Get ¶

func (m *MockleveldbCommon) Get(key []byte, ro *opt.ReadOptions) ([]byte, error)

Get mocks base method.

func (*MockleveldbCommon) Has ¶

func (m *MockleveldbCommon) Has(key []byte, ro *opt.ReadOptions) (bool, error)

Has mocks base method.

func (*MockleveldbCommon) Put ¶

func (m *MockleveldbCommon) Put(key, value []byte, ro *opt.WriteOptions) error

Put mocks base method.

type MockleveldbCommonMockRecorder ¶

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

MockleveldbCommonMockRecorder is the mock recorder for MockleveldbCommon.

func (*MockleveldbCommonMockRecorder) Get ¶

func (mr *MockleveldbCommonMockRecorder) Get(key, ro interface{}) *gomock.Call

Get indicates an expected call of Get.

func (*MockleveldbCommonMockRecorder) Has ¶

func (mr *MockleveldbCommonMockRecorder) Has(key, ro interface{}) *gomock.Call

Has indicates an expected call of Has.

func (*MockleveldbCommonMockRecorder) Put ¶

func (mr *MockleveldbCommonMockRecorder) Put(key, value, ro interface{}) *gomock.Call

Put indicates an expected call of Put.

type Store ¶

type Store interface {
	Insert(topic []byte, val *Value) error
	Ack(topic []byte, offset uint64) error
	Nack(topic []byte, offset uint64) error
	GetNext(topic []byte) (*Value, uint64, error)
	Close() error
}

func NewStore ¶

func NewStore(path string) (Store, error)

type Value ¶

type Value struct {
	Dacks uint32
	Raw   []byte
}

func Decode ¶

func Decode(buf []byte) *Value

func NewValue ¶

func NewValue(data []byte) *Value

func (*Value) Encode ¶

func (v *Value) Encode() []byte

Encode writes a value into bytes. It simply encodes the uint32 into bytes and appends the raw value after that.

Source Files ¶

View all Source files

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