etcd

Documentation

Overview

Package etcd provides objects for creating an embedded etcd server process.

This is a somewhat faithful reproduction of etcdmain/etcd.go

Index

• func DefaultEtcdClientTransport(rt http.RoundTripper) http.RoundTripper
• func EtcdClient(etcdClientInfo configapi.EtcdConnectionInfo) (*etcdclient.Client, error)
• func GetAndTestEtcdClient(etcdClientInfo configapi.EtcdConnectionInfo) (*etcdclient.Client, error)
• func RunEtcd(etcdServerConfig *configapi.EtcdConfig)
• func TestEtcdClient(etcdClient *etcdclient.Client) error

Functions

func DefaultEtcdClientTransport

func DefaultEtcdClientTransport(rt http.RoundTripper) http.RoundTripper

DefaultEtcdClientTransport sets defaults for an etcd Transport that are suitable for use by infrastructure components.

func EtcdClient

func EtcdClient(etcdClientInfo configapi.EtcdConnectionInfo) (*etcdclient.Client, error)

EtcdClient creates an etcd client based on the provided config.

func GetAndTestEtcdClient

func GetAndTestEtcdClient(etcdClientInfo configapi.EtcdConnectionInfo) (*etcdclient.Client, error)

GetAndTestEtcdClient creates an etcd client based on the provided config. It will attempt to connect to the etcd server and block until the server responds at least once, or return an error if the server never responded.

func RunEtcd

func RunEtcd(etcdServerConfig *configapi.EtcdConfig)

RunEtcd starts an etcd server and runs it forever

func TestEtcdClient

func TestEtcdClient(etcdClient *etcdclient.Client) error

TestEtcdClient verifies a client is functional. It will attempt to connect to the etcd server and block until the server responds at least once, or return an error if the server never responded.