internal

package
v1.9.4 Latest Latest
Warning

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

 Go to latest Published: Dec 23, 2025 License: MIT Imports: 22 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, exactMatch bool, l UpdateListener) error

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

func (*Registry) Unmonitor added in v1.8.0 

func (r *Registry) Unmonitor(endpoints []string, key string, exactMatch bool, l UpdateListener)

type UpdateListener 

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

UpdateListener wraps the OnAdd and OnDelete methods. The implementation should be thread-safe and idempotent.

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.