engine

Documentation

Overview

* Licensed to the Apache Software Foundation (ASF) under one * or more contributor license agreements. See the NOTICE file * distributed with this work for additional information * regarding copyright ownership. The ASF licenses this file * to you under the Apache License, Version 2.0 (the * "License"); you may not use this file except in compliance * with the License. You may obtain a copy of the License at * * http://www.apache.org/licenses/LICENSE-2.0 * * Unless required by applicable law or agreed to in writing, * software distributed under the License is distributed on an * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY * KIND, either express or implied. See the License for the * specific language governing permissions and limitations * under the License. *

Index

• type Engine
• type Entry
• type Mock
  • func NewMock() *Mock
  • func (m *Mock) Close() error
  • func (m *Mock) Delete(ctx context.Context, key string) error
  • func (m *Mock) Exists(ctx context.Context, key string) (bool, error)
  • func (m *Mock) Get(ctx context.Context, key string) ([]byte, error)
  • func (m *Mock) ID() string
  • func (m *Mock) IsReady(ctx context.Context) bool
  • func (m *Mock) Leader() string
  • func (m *Mock) LeaderChange() <-chan bool
  • func (m *Mock) List(ctx context.Context, prefix string) ([]Entry, error)
  • func (m *Mock) Set(ctx context.Context, key string, value []byte) error

Types

type Engine

type Engine interface {
	ID() string
	Leader() string
	LeaderChange() <-chan bool
	IsReady(ctx context.Context) bool

	Get(ctx context.Context, key string) ([]byte, error)
	Exists(ctx context.Context, key string) (bool, error)
	Set(ctx context.Context, key string, value []byte) error
	Delete(ctx context.Context, key string) error
	List(ctx context.Context, prefix string) ([]Entry, error)

	Close() error
}

type Entry

type Entry struct {
	Key   string
	Value []byte
}

type Mock

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

func NewMock

func NewMock() *Mock

func (*Mock) Close

func (m *Mock) Close() error

func (*Mock) Delete

func (m *Mock) Delete(ctx context.Context, key string) error

func (*Mock) Exists

func (m *Mock) Exists(ctx context.Context, key string) (bool, error)

func (*Mock) Get

func (m *Mock) Get(ctx context.Context, key string) ([]byte, error)

func (*Mock) ID

func (m *Mock) ID() string

func (*Mock) IsReady

func (m *Mock) IsReady(ctx context.Context) bool

func (*Mock) Leader

func (m *Mock) Leader() string

func (*Mock) LeaderChange

func (m *Mock) LeaderChange() <-chan bool

func (*Mock) List

func (m *Mock) List(ctx context.Context, prefix string) ([]Entry, error)

func (*Mock) Set

func (m *Mock) Set(ctx context.Context, key string, value []byte) error