client

package

Go to main page

Versions in this module

v0

v0.9.0

Jan 11, 2024

Changes in this version

type EtcdClient

+ func (cli *EtcdClient) GetGroupMembers(groupPrefix string) (map[string]string, int64, error)

+ func (cli *EtcdClient) JoinGroup(groupPrefix string, memberId string, memberContent string) error

+ func (cli *EtcdClient) LeaveGroup(groupPrefix string, memberId string) error

+ func (cli *EtcdClient) WaitGroupCountThreshold(groupPrefix string, threshold int64, doneCh <-chan struct{}) <-chan error

type WatchInfo

+ func (info *WatchInfo) ApplyOn(dest map[string]string)

v0.8.0

May 1, 2023

v0.7.0

Apr 26, 2023

Changes in this version

type KeyDiff

+ func (diff *KeyDiff) FilterKeys(fn KeyDiffFilter) *KeyDiff

+ func (diff *KeyDiff) TransformKeys(fn KeyDiffTransform) *KeyDiff

+ type KeyDiffFilter func(key string) bool

+ type KeyDiffTransform func(key string) string

v0.6.0

Apr 18, 2023

Changes in this version

+ func ErrorIsRetryable(err error) bool

type EtcdClient

+ func (cli *EtcdClient) ChangeLeader() error

+ func (cli *EtcdClient) GetMembers(statusInfo bool) (EtcdMembers, error)

+ func (cli *EtcdClient) SetEndpoints(endpoints []string) (*EtcdClient, error)

+ func (cli *EtcdClient) SetLeaderStatus(name string, isLeader bool) error

+ func (cli *EtcdClient) Watch(wKey string, opts WatchOptions) <-chan WatchNotification

+ type EtcdMember struct

+ ClientUrls []string

+ Id uint64

+ IsLearner bool

+ Name string

+ PeerUrls []string

+ Status *EtcdMemberStatus

+ type EtcdMemberStatus struct

+ DbSize int64

+ DbSizeInUse int64

+ IsLeader bool

+ IsResponsive bool

+ ProtocolVersion string

+ RaftAppliedIndex uint64

+ RaftIndex uint64

+ RaftTerm uint64

+ ResponseError error

+ type EtcdMembers struct

+ ClusterId uint64

+ Members []EtcdMember

+ RespId uint64

+ RespRaftTerm uint64

+ RespRevision int64

+ type GetKeyOptions struct

+ Revision int64

+ type KeyDiff struct

+ Deletions []string

+ Inserts map[string]string

+ Updates map[string]string

+ func GetKeyDiff(src map[string]string, dst map[string]string) KeyDiff

+ func (diff *KeyDiff) IsEmpty() bool

type KeyInfo

+ func (info *KeyInfo) Found() bool

+ type KeyInfoMap map[string]KeyInfo

+ func (info *KeyInfoMap) ToValueMap(prefixTrim string) map[string]string

+ type KeyRangeInfo struct

+ Keys KeyInfoMap

+ Revision int64

+ type WatchKeyInfo struct

+ CreateRevision int64

+ Lease int64

+ ModRevision int64

+ Value string

+ Version int64

+ type WatchNotification struct

+ Changes WatchInfo

+ Error error

+ type WatchOptions struct

+ IsPrefix bool

+ Revision int64

+ TrimPrefix bool

v0.5.0

Apr 9, 2023

Changes in this version

+ func KeyIsPresent(key string, presence bool) clientv3.Cmp

+ func KeyValueIsCmp(key string, cmp string, value string) clientv3.Cmp

+ func KeyVersionIsCmp(key string, cmp string, value int64) clientv3.Cmp

type AcquireLockOptions

+ ExtraConditions []clientv3.Cmp

+ type ChunkedKeyInfo struct

+ Count int64

+ Size int64

+ Version int64

+ type ChunkedKeyPayload struct

+ Key string

+ Size int64

+ Value io.ReadCloser

+ func (p *ChunkedKeyPayload) Close() error

+ func (p *ChunkedKeyPayload) Read(r []byte) (n int, err error)

+ type ChunkedKeySnapshot struct

+ Info ChunkedKeyInfo

+ Revision int64

type EtcdClient

+ Context context.Context

+ RetryInterval time.Duration

+ func (cli *EtcdClient) GetAuthStatus() (bool, error)

+ func (cli *EtcdClient) SetAuthStatus(enable bool) error

+ func (cli *EtcdClient) SetContext(ctx context.Context) *EtcdClient

type EtcdClientOptions

+ RetryInterval time.Duration

+ SkipTLS bool

+ type KeyInfo struct

+ CreateRevision int64

+ Key string

+ Lease int64

+ ModRevision int64

+ Value string

+ Version int64

+ type KeyWatchInfo struct

+ CreateRevision int64

+ Lease int64

+ ModRevision int64

+ Value string

+ Version int64

+ type KeysDiff struct

+ Deletions []string

+ Upserts map[string]string

+ func GetKeysDiff(srcKeys map[string]KeyInfo, srcPrefix string, dstKeys map[string]KeyInfo, ...) KeysDiff

+ func (diff *KeysDiff) IsEmpty() bool

+ type Lock struct

+ Lease clientv3.LeaseID

+ Revision int64

+ Timestamp time.Time

+ Ttl int64

+ type WatchInfo struct

+ Deletions []string

+ Upserts map[string]KeyWatchInfo

v0.4.0

Mar 22, 2023

v0.3.0

Mar 22, 2023

v0.2.1

Dec 2, 2022

v0.2.0

Nov 11, 2022

Changes in this version

type EtcdClient

+ func (cli *EtcdClient) ChangeUserPassword(username string, password string) error

+ func (cli *EtcdClient) DeleteRole(name string) error

+ func (cli *EtcdClient) DeleteUser(username string) error

+ func (cli *EtcdClient) GetPrefix(prefix string) (map[string]keymodels.KeyInfo, int64, error)

+ func (cli *EtcdClient) GetRolePermissions(name string) ([]EtcdRolePermission, bool, error)

+ func (cli *EtcdClient) GetUserRoles(username string) ([]string, bool, error)

+ func (cli *EtcdClient) GrantRolePermission(name string, permission EtcdRolePermission) error

+ func (cli *EtcdClient) GrantUserRole(username string, role string) error

+ func (cli *EtcdClient) InsertEmptyRole(name string) error

+ func (cli *EtcdClient) InsertEmptyUser(username string, password string) error

+ func (cli *EtcdClient) InsertRole(role EtcdRole) error

+ func (cli *EtcdClient) InsertUser(user EtcdUser) error

+ func (cli *EtcdClient) ListRoles() ([]string, error)

+ func (cli *EtcdClient) ListUsers() ([]string, error)

+ func (cli *EtcdClient) RevokeRolePermission(name string, key string, rangeEnd string) error

+ func (cli *EtcdClient) RevokeUserRole(username string, role string) error

+ func (cli *EtcdClient) UpdateRole(role EtcdRole) error

+ func (cli *EtcdClient) UpdateUser(user EtcdUser) error

+ func (cli *EtcdClient) UpsertRole(role EtcdRole) error

+ func (cli *EtcdClient) UpsertUser(user EtcdUser) error

+ type EtcdRole struct

+ Name string

+ Permissions []EtcdRolePermission

+ type EtcdRolePermission struct

+ Key string

+ Permission string

+ RangeEnd string

+ type EtcdUser struct

+ Password string

+ Roles []string

+ Username string

v0.1.2

Oct 7, 2022

v0.1.1

Oct 6, 2022

v0.1.0

Oct 5, 2022

Changes in this version

+ type AcquireLockOptions struct

+ Key string

+ RetryInterval time.Duration

+ Timeout time.Duration

+ Ttl int64

+ type ChunksReader struct

+ Buffer *bytes.Buffer

+ Client *EtcdClient

+ Index int64

+ Key string

+ Snapshot keymodels.ChunkedKeySnapshot

+ func (r *ChunksReader) Close() error

+ func (r *ChunksReader) Read(p []byte) (n int, err error)

+ type EtcdClient struct

+ Client *clientv3.Client

+ RequestTimeout time.Duration

+ Retries uint64

+ func Connect(opts EtcdClientOptions) (*EtcdClient, error)

+ func (cli *EtcdClient) AcquireLock(opts AcquireLockOptions) (*keymodels.Lock, bool, error)

+ func (cli *EtcdClient) ApplyDiffToPrefix(prefix string, diff keymodels.KeysDiff) error

+ func (cli *EtcdClient) Close()

+ func (cli *EtcdClient) DeleteChunkedKey(key string) error

+ func (cli *EtcdClient) DeleteChunkedKeyWithRetries(key string, retries uint64) error

+ func (cli *EtcdClient) DeleteKey(key string) error

+ func (cli *EtcdClient) DeleteKeyRange(key string, rangeEnd string) error

+ func (cli *EtcdClient) DeletePrefix(prefix string) error

+ func (cli *EtcdClient) DiffBetweenPrefixes(srcPrefix string, dstPrefix string) (keymodels.KeysDiff, error)

+ func (cli *EtcdClient) DiffPrefixWithMap(prefix string, inputKeys map[string]keymodels.KeyInfo, inputKeysPrefix string, ...) (keymodels.KeysDiff, error)

+ func (cli *EtcdClient) GetChunkedKey(key string) (*keymodels.ChunkedKeyPayload, error)

+ func (cli *EtcdClient) GetKey(key string) (keymodels.KeyInfo, bool, error)

+ func (cli *EtcdClient) GetKeyAtRevision(key string, revision int64) (keymodels.KeyInfo, bool, error)

+ func (cli *EtcdClient) GetKeyRange(key string, rangeEnd string) (map[string]keymodels.KeyInfo, int64, error)

+ func (cli *EtcdClient) PutChunkedKey(key *keymodels.ChunkedKeyPayload) error

+ func (cli *EtcdClient) PutKey(key string, val string) error

+ func (cli *EtcdClient) ReadLock(key string) (*keymodels.Lock, error)

+ func (cli *EtcdClient) ReleaseLock(key string) error

+ func (cli *EtcdClient) WatchPrefixChanges(prefix string, revision int64) <-chan PrefixChangesResult

+ type EtcdClientOptions struct

+ CaCertPath string

+ ClientCertPath string

+ ClientKeyPath string

+ ConnectionTimeout time.Duration

+ EtcdEndpoints []string

+ Password string

+ RequestTimeout time.Duration

+ Retries uint64

+ Username string

+ type PrefixChangesResult struct

+ Changes keymodels.KeysDiff

+ Error error

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