internal

package
v1.5.7 Latest Latest
Warning

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

 Go to latest Published: Oct 11, 2023 License: MIT Imports: 20 Imported by: 0

Documentation

Overview

Package internal is a generated GoMock package.

Package internal is a generated GoMock package.

Package internal is a generated GoMock package.

Index

Constants

View Source 
const (
	// Delimiter is a separator that separates the etcd path.
	Delimiter = '/'
)

Variables

View Source 
var (
	// DialTimeout is the dial timeout.
	DialTimeout = dialTimeout
	// RequestTimeout is the request timeout.
	RequestTimeout = requestTimeout
	// NewClient is used to create etcd clients.
	NewClient = DialClient
)

Functions

func AddAccount 

func AddAccount(endpoints []string, user, pass string)

AddAccount adds the username/password for the given etcd cluster.

func AddTLS 

func AddTLS(endpoints []string, certFile, certKeyFile, caFile string, insecureSkipVerify bool) error

AddTLS adds the tls cert files for the given etcd cluster.

func GetTLS 

func GetTLS(endpoints []string) (*tls.Config, bool)

GetTLS gets the tls config for the given etcd cluster.

Types

type Account 

type Account struct {
	User string
	Pass string
}

Account holds the username/password for an etcd cluster.

func GetAccount 

func GetAccount(endpoints []string) (Account, bool)

GetAccount gets the username/password for the given etcd cluster.

type EtcdClient 

type EtcdClient interface {
	ActiveConnection() *grpc.ClientConn
	Close() error
	Ctx() context.Context
	Get(ctx context.Context, key string, opts ...clientv3.OpOption) (*clientv3.GetResponse, error)
	Grant(ctx context.Context, ttl int64) (*clientv3.LeaseGrantResponse, error)
	KeepAlive(ctx context.Context, id clientv3.LeaseID) (<-chan *clientv3.LeaseKeepAliveResponse, error)
	Put(ctx context.Context, key, val string, opts ...clientv3.OpOption) (*clientv3.PutResponse, error)
	Revoke(ctx context.Context, id clientv3.LeaseID) (*clientv3.LeaseRevokeResponse, error)
	Watch(ctx context.Context, key string, opts ...clientv3.OpOption) clientv3.WatchChan
}

EtcdClient interface represents an etcd client.

func DialClient 

func DialClient(endpoints []string) (EtcdClient, error)

DialClient dials an etcd cluster with given endpoints.

type KV 

type KV struct {
	Key string
	Val string
}

A KV is used to store an etcd entry with key and value.

type Listener 

type Listener interface {
	OnUpdate(keys, values []string, newKey string)
}

Listener interface wraps the OnUpdate method.

type MockEtcdClient 

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

MockEtcdClient is a mock of EtcdClient interface

func NewMockEtcdClient 

func NewMockEtcdClient(ctrl *gomock.Controller) *MockEtcdClient

NewMockEtcdClient creates a new mock instance

func (*MockEtcdClient) ActiveConnection 

func (m *MockEtcdClient) ActiveConnection() *grpc.ClientConn

ActiveConnection mocks base method

func (*MockEtcdClient) Close 

func (m *MockEtcdClient) Close() error

Close mocks base method

func (*MockEtcdClient) Ctx 

func (m *MockEtcdClient) Ctx() context.Context

Ctx mocks base method

func (*MockEtcdClient) EXPECT 

func (m *MockEtcdClient) EXPECT() *MockEtcdClientMockRecorder

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

func (*MockEtcdClient) Get 

func (m *MockEtcdClient) Get(ctx context.Context, key string, opts ...clientv3.OpOption) (*clientv3.GetResponse, error)

Get mocks base method

func (*MockEtcdClient) Grant 

func (m *MockEtcdClient) Grant(ctx context.Context, ttl int64) (*clientv3.LeaseGrantResponse, error)

Grant mocks base method

func (*MockEtcdClient) KeepAlive 

func (m *MockEtcdClient) KeepAlive(ctx context.Context, id clientv3.LeaseID) (<-chan *clientv3.LeaseKeepAliveResponse, error)

KeepAlive mocks base method

func (*MockEtcdClient) Put 

func (m *MockEtcdClient) Put(ctx context.Context, key, val string, opts ...clientv3.OpOption) (*clientv3.PutResponse, error)

Put mocks base method

func (*MockEtcdClient) Revoke 

func (m *MockEtcdClient) Revoke(ctx context.Context, id clientv3.LeaseID) (*clientv3.LeaseRevokeResponse, error)

Revoke mocks base method

func (*MockEtcdClient) Watch 

func (m *MockEtcdClient) Watch(ctx context.Context, key string, opts ...clientv3.OpOption) clientv3.WatchChan

Watch mocks base method

type MockEtcdClientMockRecorder 

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

MockEtcdClientMockRecorder is the mock recorder for MockEtcdClient

func (*MockEtcdClientMockRecorder) ActiveConnection 

func (mr *MockEtcdClientMockRecorder) ActiveConnection() *gomock.Call

ActiveConnection indicates an expected call of ActiveConnection

func (*MockEtcdClientMockRecorder) Close 

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

Close indicates an expected call of Close

func (*MockEtcdClientMockRecorder) Ctx 

func (mr *MockEtcdClientMockRecorder) Ctx() *gomock.Call

Ctx indicates an expected call of Ctx

func (*MockEtcdClientMockRecorder) Get 

func (mr *MockEtcdClientMockRecorder) Get(ctx, key any, opts ...any) *gomock.Call

Get indicates an expected call of Get

func (*MockEtcdClientMockRecorder) Grant 

func (mr *MockEtcdClientMockRecorder) Grant(ctx, ttl any) *gomock.Call

Grant indicates an expected call of Grant

func (*MockEtcdClientMockRecorder) KeepAlive 

func (mr *MockEtcdClientMockRecorder) KeepAlive(ctx, id any) *gomock.Call

KeepAlive indicates an expected call of KeepAlive

func (*MockEtcdClientMockRecorder) Put 

func (mr *MockEtcdClientMockRecorder) Put(ctx, key, val any, opts ...any) *gomock.Call

Put indicates an expected call of Put

func (*MockEtcdClientMockRecorder) Revoke 

func (mr *MockEtcdClientMockRecorder) Revoke(ctx, id any) *gomock.Call

Revoke indicates an expected call of Revoke

func (*MockEtcdClientMockRecorder) Watch 

func (mr *MockEtcdClientMockRecorder) Watch(ctx, key any, opts ...any) *gomock.Call

Watch indicates an expected call of Watch

type MockUpdateListener 

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

MockUpdateListener is a mock of UpdateListener interface

func NewMockUpdateListener 

func NewMockUpdateListener(ctrl *gomock.Controller) *MockUpdateListener

NewMockUpdateListener creates a new mock instance

func (*MockUpdateListener) EXPECT 

func (m *MockUpdateListener) EXPECT() *MockUpdateListenerMockRecorder

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

func (*MockUpdateListener) OnAdd 

func (m *MockUpdateListener) OnAdd(kv KV)

OnAdd mocks base method

func (*MockUpdateListener) OnDelete 

func (m *MockUpdateListener) OnDelete(kv KV)

OnDelete mocks base method

type MockUpdateListenerMockRecorder 

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

MockUpdateListenerMockRecorder is the mock recorder for MockUpdateListener

func (*MockUpdateListenerMockRecorder) OnAdd 

func (mr *MockUpdateListenerMockRecorder) OnAdd(kv any) *gomock.Call

OnAdd indicates an expected call of OnAdd

func (*MockUpdateListenerMockRecorder) OnDelete 

func (mr *MockUpdateListenerMockRecorder) OnDelete(kv any) *gomock.Call

OnDelete indicates an expected call of OnDelete

type MocketcdConn 

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

MocketcdConn is a mock of etcdConn interface

func NewMocketcdConn 

func NewMocketcdConn(ctrl *gomock.Controller) *MocketcdConn

NewMocketcdConn creates a new mock instance

func (*MocketcdConn) EXPECT 

func (m *MocketcdConn) EXPECT() *MocketcdConnMockRecorder

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

func (*MocketcdConn) GetState 

func (m *MocketcdConn) GetState() connectivity.State

GetState mocks base method

func (*MocketcdConn) WaitForStateChange 

func (m *MocketcdConn) WaitForStateChange(ctx context.Context, sourceState connectivity.State) bool

WaitForStateChange mocks base method

type MocketcdConnMockRecorder 

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

MocketcdConnMockRecorder is the mock recorder for MocketcdConn

func (*MocketcdConnMockRecorder) GetState 

func (mr *MocketcdConnMockRecorder) GetState() *gomock.Call

GetState indicates an expected call of GetState

func (*MocketcdConnMockRecorder) WaitForStateChange 

func (mr *MocketcdConnMockRecorder) WaitForStateChange(ctx, sourceState any) *gomock.Call

WaitForStateChange indicates an expected call of WaitForStateChange

type Registry 

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

A Registry is a registry that manages the etcd client connections.

func GetRegistry 

func GetRegistry() *Registry

GetRegistry returns a global Registry.

func (*Registry) GetConn 

func (r *Registry) GetConn(endpoints []string) (EtcdClient, error)

GetConn returns an etcd client connection associated with given endpoints.

func (*Registry) Monitor 

func (r *Registry) Monitor(endpoints []string, key string, l UpdateListener) error

Monitor monitors the key on given etcd endpoints, notify with the given UpdateListener.

type UpdateListener 

type UpdateListener interface {
	OnAdd(kv KV)
	OnDelete(kv KV)
}

UpdateListener wraps the OnAdd and OnDelete methods.

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.