server

package

Go to main page

Versions in this module

v0

v0.11.10

Jun 4, 2024

v0.11.10-rc1

Jun 4, 2024

v0.11.9

May 9, 2024

Changes in this version

type Backend

+ Compact func(ctx context.Context, revision int64) (int64, error)

type LimitedServer

+ func (l *LimitedServer) Compact(ctx context.Context, r *etcdserverpb.CompactionRequest) (*etcdserverpb.CompactionResponse, error)

v0.11.8

Apr 30, 2024

v0.11.7

Mar 26, 2024

v0.11.6

Mar 13, 2024

v0.11.5

Mar 1, 2024

v0.11.4

Feb 2, 2024

Changes in this version

type Dialect

+ CountCurrent func(ctx context.Context, prefix string) (int64, int64, error)

v0.11.3

Jan 10, 2024

v0.11.2

Dec 7, 2023

Changes in this version

+ func GetProgressReportInterval() time.Duration

type Backend

+ CurrentRevision func(ctx context.Context) (int64, error)

v0.11.1

Nov 28, 2023

v0.11.0

Nov 10, 2023

Changes in this version

+ var ErrFutureRev = rpctypes.ErrGRPCFutureRev

+ var ErrNotSupported = status.New(codes.InvalidArgument, "etcdserver: unsupported operations in txn request").Err()

type Dialect

+ FillRetryDelay func(ctx context.Context)

+ type WatchResult struct

+ CompactRevision int64

+ CurrentRevision int64

+ Events <-chan []*Event

v0.10.3

Aug 29, 2023

v0.10.2

Jul 31, 2023

v0.10.1

May 5, 2023

v0.10.0

Apr 26, 2023

v0.9.9

Feb 16, 2023

v0.9.9-rc1

Jan 26, 2023

v0.9.8

Nov 21, 2022

v0.9.7

Nov 18, 2022

v0.9.6

Oct 25, 2022

v0.9.6-rc.2

Oct 25, 2022

v0.9.6-rc.1

Oct 24, 2022

v0.9.5

Oct 21, 2022

v0.9.4

Sep 8, 2022

v0.9.3

Jul 1, 2022

v0.9.2

Jun 14, 2022

v0.9.1

Apr 28, 2022

v0.9.0

Apr 8, 2022

v0.8.1

Nov 16, 2021

Changes in this version

type Dialect

+ PostCompact func(ctx context.Context) error

v0.8.1-drone

Nov 16, 2021

v0.8.0

Aug 31, 2021

Changes in this version

type Backend

+ DbSize func(ctx context.Context) (int64, error)

+ type Dialect interface

+ After func(ctx context.Context, prefix string, rev, limit int64) (*sql.Rows, error)

+ BeginTx func(ctx context.Context, opts *sql.TxOptions) (Transaction, error)

+ Compact func(ctx context.Context, revision int64) (int64, error)

+ Count func(ctx context.Context, prefix string) (int64, int64, error)

+ CurrentRevision func(ctx context.Context) (int64, error)

+ DeleteRevision func(ctx context.Context, revision int64) error

+ Fill func(ctx context.Context, revision int64) error

+ GetCompactRevision func(ctx context.Context) (int64, error)

+ GetRevision func(ctx context.Context, revision int64) (*sql.Rows, error)

+ GetSize func(ctx context.Context) (int64, error)

+ Insert func(ctx context.Context, key string, create, delete bool, ...) (int64, error)

+ IsFill func(key string) bool

+ List func(ctx context.Context, prefix, startKey string, limit, revision int64, ...) (*sql.Rows, error)

+ ListCurrent func(ctx context.Context, prefix string, limit int64, includeDeleted bool) (*sql.Rows, error)

+ SetCompactRevision func(ctx context.Context, revision int64) error

type KVServerBridge

+ func (s *KVServerBridge) Alarm(context.Context, *etcdserverpb.AlarmRequest) (*etcdserverpb.AlarmResponse, error)

+ func (s *KVServerBridge) Defragment(context.Context, *etcdserverpb.DefragmentRequest) (*etcdserverpb.DefragmentResponse, error)

+ func (s *KVServerBridge) Downgrade(context.Context, *etcdserverpb.DowngradeRequest) (*etcdserverpb.DowngradeResponse, error)

+ func (s *KVServerBridge) Hash(context.Context, *etcdserverpb.HashRequest) (*etcdserverpb.HashResponse, error)

+ func (s *KVServerBridge) HashKV(context.Context, *etcdserverpb.HashKVRequest) (*etcdserverpb.HashKVResponse, error)

+ func (s *KVServerBridge) MemberAdd(context.Context, *etcdserverpb.MemberAddRequest) (*etcdserverpb.MemberAddResponse, error)

+ func (s *KVServerBridge) MemberList(ctx context.Context, r *etcdserverpb.MemberListRequest) (*etcdserverpb.MemberListResponse, error)

+ func (s *KVServerBridge) MemberPromote(context.Context, *etcdserverpb.MemberPromoteRequest) (*etcdserverpb.MemberPromoteResponse, error)

+ func (s *KVServerBridge) MemberRemove(context.Context, *etcdserverpb.MemberRemoveRequest) (*etcdserverpb.MemberRemoveResponse, error)

+ func (s *KVServerBridge) MemberUpdate(context.Context, *etcdserverpb.MemberUpdateRequest) (*etcdserverpb.MemberUpdateResponse, error)

+ func (s *KVServerBridge) MoveLeader(context.Context, *etcdserverpb.MoveLeaderRequest) (*etcdserverpb.MoveLeaderResponse, error)

+ func (s *KVServerBridge) Snapshot(*etcdserverpb.SnapshotRequest, etcdserverpb.Maintenance_SnapshotServer) error

+ func (s *KVServerBridge) Status(ctx context.Context, r *etcdserverpb.StatusRequest) (*etcdserverpb.StatusResponse, error)

+ type Transaction interface

+ Commit func() error

+ Compact func(ctx context.Context, revision int64) (int64, error)

+ CurrentRevision func(ctx context.Context) (int64, error)

+ DeleteRevision func(ctx context.Context, revision int64) error

+ GetCompactRevision func(ctx context.Context) (int64, error)

+ GetRevision func(ctx context.Context, revision int64) (*sql.Rows, error)

+ MustCommit func()

+ MustRollback func()

+ Rollback func() error

+ SetCompactRevision func(ctx context.Context, revision int64) error

v0.7.3

Aug 18, 2021

v0.7.2

Jul 28, 2021

v0.7.1

Jul 14, 2021

v0.7.0

Jul 13, 2021

v0.6.5

Dec 8, 2021

v0.6.4

Jul 28, 2021

v0.6.3

Jul 14, 2021

v0.6.2

Jun 29, 2021

v0.6.1

Jun 11, 2021

v0.6.1-rc.1

Nov 20, 2020

v0.6.0

Nov 20, 2020

Changes in this version

+ var ErrCompacted = rpctypes.ErrGRPCCompacted

+ var ErrKeyExists = rpctypes.ErrGRPCDuplicateKey

+ type Backend interface

+ Count func(ctx context.Context, prefix string) (int64, int64, error)

+ Create func(ctx context.Context, key string, value []byte, lease int64) (int64, error)

+ Delete func(ctx context.Context, key string, revision int64) (int64, *KeyValue, bool, error)

+ Get func(ctx context.Context, key string, revision int64) (int64, *KeyValue, error)

+ List func(ctx context.Context, prefix, startKey string, limit, revision int64) (int64, []*KeyValue, error)

+ Start func(ctx context.Context) error

+ Update func(ctx context.Context, key string, value []byte, revision, lease int64) (int64, *KeyValue, bool, error)

+ Watch func(ctx context.Context, key string, revision int64) <-chan []*Event

+ type Event struct

+ Create bool

+ Delete bool

+ KV *KeyValue

+ PrevKV *KeyValue

+ type KVServerBridge struct

+ func New(backend Backend) *KVServerBridge

+ func (k *KVServerBridge) Compact(ctx context.Context, r *etcdserverpb.CompactionRequest) (*etcdserverpb.CompactionResponse, error)

+ func (k *KVServerBridge) DeleteRange(ctx context.Context, r *etcdserverpb.DeleteRangeRequest) (*etcdserverpb.DeleteRangeResponse, error)

+ func (k *KVServerBridge) Put(ctx context.Context, r *etcdserverpb.PutRequest) (*etcdserverpb.PutResponse, error)

+ func (k *KVServerBridge) Range(ctx context.Context, r *etcdserverpb.RangeRequest) (*etcdserverpb.RangeResponse, error)

+ func (k *KVServerBridge) Register(server *grpc.Server)

+ func (k *KVServerBridge) Txn(ctx context.Context, r *etcdserverpb.TxnRequest) (*etcdserverpb.TxnResponse, error)

+ func (s *KVServerBridge) LeaseGrant(ctx context.Context, req *etcdserverpb.LeaseGrantRequest) (*etcdserverpb.LeaseGrantResponse, error)

+ func (s *KVServerBridge) LeaseKeepAlive(etcdserverpb.Lease_LeaseKeepAliveServer) error

+ func (s *KVServerBridge) LeaseLeases(context.Context, *etcdserverpb.LeaseLeasesRequest) (*etcdserverpb.LeaseLeasesResponse, error)

+ func (s *KVServerBridge) LeaseRevoke(context.Context, *etcdserverpb.LeaseRevokeRequest) (*etcdserverpb.LeaseRevokeResponse, error)

+ func (s *KVServerBridge) LeaseTimeToLive(context.Context, *etcdserverpb.LeaseTimeToLiveRequest) (*etcdserverpb.LeaseTimeToLiveResponse, error)

+ func (s *KVServerBridge) Watch(ws etcdserverpb.Watch_WatchServer) error

+ type KeyValue struct

+ CreateRevision int64

+ Key string

+ Lease int64

+ ModRevision int64

+ Value []byte

+ type LimitedServer struct

+ func (l *LimitedServer) Range(ctx context.Context, r *etcdserverpb.RangeRequest) (*RangeResponse, error)

+ func (l *LimitedServer) Txn(ctx context.Context, txn *etcdserverpb.TxnRequest) (*etcdserverpb.TxnResponse, error)

+ type RangeResponse struct

+ Count int64

+ Header *etcdserverpb.ResponseHeader

+ Kvs []*KeyValue

+ More bool

+ type ResponseHeader struct

+ Revision int64

v0.6.0-rc.2

Nov 20, 2020

v0.6.0-rc.1

Nov 20, 2020

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