store

Documentation

Overview

Package store is a generated GoMock package.

Index

• Variables
• type EtcdWatcher
• type MockEtcdWatcher
  • func NewMockEtcdWatcher(ctrl *gomock.Controller) *MockEtcdWatcher
  • func (m *MockEtcdWatcher) Close() error
  • func (m *MockEtcdWatcher) EXPECT() *MockEtcdWatcherMockRecorder
  • func (m *MockEtcdWatcher) WatchChan() clientv3.WatchChan
• type MockEtcdWatcherMockRecorder
  • func (mr *MockEtcdWatcherMockRecorder) Close() *gomock.Call
  • func (mr *MockEtcdWatcherMockRecorder) WatchChan() *gomock.Call
• type Registration
• type Store
  • func New(c *config.Config) Store
• type Watcher
  • func NewWatcher(ctx context.Context, config *config.Config, opts ...WatcherOpt) (Watcher, error)
  • func (w Watcher) Close() error
  • func (w Watcher) Register(key string) (Registration, error)
• type WatcherOpt
  • func WithEtcdWatcher(etcdWatcher EtcdWatcher) WatcherOpt
  • func WithPrefix(prefix string) WatcherOpt

Variables

var ErrNotFound = errors.New("not found")

Types

type EtcdWatcher

type EtcdWatcher interface {
	WatchChan() clientv3.WatchChan
	Close() error
}

type MockEtcdWatcher

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

MockEtcdWatcher is a mock of EtcdWatcher interface

func NewMockEtcdWatcher

func NewMockEtcdWatcher(ctrl *gomock.Controller) *MockEtcdWatcher

NewMockEtcdWatcher creates a new mock instance

func (*MockEtcdWatcher) Close

func (m *MockEtcdWatcher) Close() error

Close mocks base method

func (*MockEtcdWatcher) EXPECT

func (m *MockEtcdWatcher) EXPECT() *MockEtcdWatcherMockRecorder

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

func (*MockEtcdWatcher) WatchChan

func (m *MockEtcdWatcher) WatchChan() clientv3.WatchChan

WatchChan mocks base method

type MockEtcdWatcherMockRecorder

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

MockEtcdWatcherMockRecorder is the mock recorder for MockEtcdWatcher

func (*MockEtcdWatcherMockRecorder) Close

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

Close indicates an expected call of Close

func (*MockEtcdWatcherMockRecorder) WatchChan

func (mr *MockEtcdWatcherMockRecorder) WatchChan() *gomock.Call

WatchChan indicates an expected call of WatchChan

type Registration

type Registration interface {
	EventChan() <-chan *clientv3.Event
	Unregister()
}

type Store

type Store interface {
	Get(ctx context.Context, key string, recursive bool, data interface{}) error
	GetWithRevision(ctx context.Context, key string, rev int64, recursive bool, data interface{}) error
	Set(ctx context.Context, key string, data interface{}) error
	Delete(ctx context.Context, key string) error
}

func New

func New(c *config.Config) Store

type Watcher

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

func NewWatcher

func NewWatcher(ctx context.Context, config *config.Config, opts ...WatcherOpt) (Watcher, error)

func (Watcher) Close

func (w Watcher) Close() error

func (Watcher) Register

func (w Watcher) Register(key string) (Registration, error)

type WatcherOpt

type WatcherOpt func(w *Watcher)

func WithEtcdWatcher

func WithEtcdWatcher(etcdWatcher EtcdWatcher) WatcherOpt

func WithPrefix

func WithPrefix(prefix string) WatcherOpt