Versions in this module Expand all Collapse all v0 v0.1.0 Jun 15, 2023 Changes in this version + const DefaultDialTimeout + const DefaultRequestTimeout + const DefaultSlowRequestTime + func AddEtcdMember(client *clientv3.Client, urls []string) (*clientv3.MemberAddResponse, error) + func CheckClusterID(localClusterID types.ID, um types.URLsMap, tlsConfig *tls.Config) error + func CreateClients(tlsConfig *tls.Config, acUrls url.URL) (*clientv3.Client, *http.Client, error) + func CreateClientsWithMultiEndpoint(tlsConfig *tls.Config, acUrls []url.URL) (*clientv3.Client, *http.Client, error) + func CreateEtcdClient(tlsConfig *tls.Config, acURL url.URL) (*clientv3.Client, error) + func EtcdKVGet(c *clientv3.Client, key string, opts ...clientv3.OpOption) (*clientv3.GetResponse, error) + func EtcdKVPutWithTTL(ctx context.Context, c *clientv3.Client, key string, value string, ...) (*clientv3.PutResponse, error) + func GetClusterID(c *clientv3.Client, key string) (clusterID uint64, err error) + func GetProtoMsgWithModRev(c *clientv3.Client, key string, msg proto.Message, opts ...clientv3.OpOption) (bool, int64, error) + func GetValue(c *clientv3.Client, key string, opts ...clientv3.OpOption) ([]byte, error) + func InitClusterID(c *clientv3.Client, key string) (clusterID uint64, err error) + func InitOrGetClusterID(c *clientv3.Client, key string) (uint64, error) + func ListEtcdMembers(client *clientv3.Client) (*clientv3.MemberListResponse, error) + func NewTestSingleConfig(t *testing.T) *embed.Config + func RemoveEtcdMember(client *clientv3.Client, id uint64) (*clientv3.MemberRemoveResponse, error)