etcd

Documentation

Index

• func GetEtcdClient(ctx context.Context, certificates *Certificates, endpoints ...string) (*clientv3.Client, error)
• func WaitForEtcdClient(parentCtx context.Context, certificates *Certificates, endpoints ...string) (*clientv3.Client, error)
• type Certificates
  • func EndpointsAndCertificatesFromFlags(flags []string) ([]string, *Certificates, error)

Functions

func GetEtcdClient

func GetEtcdClient(ctx context.Context, certificates *Certificates, endpoints ...string) (*clientv3.Client, error)

GetEtcdClient returns an etcd client connected to the specified endpoints. If no endpoints are provided, endpoints are retrieved from the provided runtime config. If the runtime config does not list any endpoints, the default endpoint is used. The returned client should be closed when no longer needed, in order to avoid leaking GRPC client goroutines.

func WaitForEtcdClient

func WaitForEtcdClient(parentCtx context.Context, certificates *Certificates, endpoints ...string) (*clientv3.Client, error)

Types

type Certificates

type Certificates struct {
	CaCert     string
	ServerCert string
	ServerKey  string
}

func EndpointsAndCertificatesFromFlags

func EndpointsAndCertificatesFromFlags(flags []string) ([]string, *Certificates, error)