Documentation ¶
Index ¶
- type EtcdClient
- func (c *EtcdClient) Apply(d *model.KVPair) (*model.KVPair, error)
- func (c *EtcdClient) Create(d *model.KVPair) (*model.KVPair, error)
- func (c *EtcdClient) Delete(d *model.KVPair) error
- func (c *EtcdClient) EnsureCalicoNodeInitialized(node string) error
- func (c *EtcdClient) EnsureInitialized() error
- func (c *EtcdClient) Get(k model.Key) (*model.KVPair, error)
- func (c *EtcdClient) List(l model.ListInterface) ([]*model.KVPair, error)
- func (c *EtcdClient) Syncer(callbacks api.SyncerCallbacks) api.Syncer
- func (c *EtcdClient) Update(d *model.KVPair) (*model.KVPair, error)
- type EtcdConfig
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type EtcdClient ¶
type EtcdClient struct {
// contains filtered or unexported fields
}
func NewEtcdClient ¶
func NewEtcdClient(config *EtcdConfig) (*EtcdClient, error)
func (*EtcdClient) Apply ¶
Set an existing entry in the datastore. This ignores whether an entry already exists.
func (*EtcdClient) Create ¶
Create an entry in the datastore. This errors if the entry already exists.
func (*EtcdClient) Delete ¶
func (c *EtcdClient) Delete(d *model.KVPair) error
Delete an entry in the datastore. This errors if the entry does not exists.
func (*EtcdClient) EnsureCalicoNodeInitialized ¶ added in v1.0.1
func (c *EtcdClient) EnsureCalicoNodeInitialized(node string) error
EnsureCalicoNodeInitialized() performs additional initialization required by the calico/node components startup/ipip-allocation/confd. This is a temporary requirement until the calico/node components are updated to not require special etcd setup, or until the global and per-node config is reworked to allow the node to perform the necessary updates.
func (*EtcdClient) EnsureInitialized ¶
func (c *EtcdClient) EnsureInitialized() error
EnsureInitialized makes sure that the etcd data is initialized for use by Calico.
func (*EtcdClient) Get ¶
Get an entry from the datastore. This errors if the entry does not exist.
func (*EtcdClient) List ¶
func (c *EtcdClient) List(l model.ListInterface) ([]*model.KVPair, error)
List entries in the datastore. This may return an empty list of there are no entries matching the request in the ListInterface.
func (*EtcdClient) Syncer ¶
func (c *EtcdClient) Syncer(callbacks api.SyncerCallbacks) api.Syncer
type EtcdConfig ¶
type EtcdConfig struct { EtcdScheme string `json:"etcdScheme" envconfig:"ETCD_SCHEME" default:"http"` EtcdAuthority string `json:"etcdAuthority" envconfig:"ETCD_AUTHORITY" default:"127.0.0.1:2379"` EtcdEndpoints string `json:"etcdEndpoints" envconfig:"ETCD_ENDPOINTS"` EtcdUsername string `json:"etcdUsername" envconfig:"ETCD_USERNAME"` EtcdPassword string `json:"etcdPassword" envconfig:"ETCD_PASSWORD"` EtcdKeyFile string `json:"etcdKeyFile" envconfig:"ETCD_KEY_FILE"` EtcdCertFile string `json:"etcdCertFile" envconfig:"ETCD_CERT_FILE"` EtcdCACertFile string `json:"etcdCACertFile" envconfig:"ETCD_CA_CERT_FILE"` }