etcd

package

v0.1.2 Latest Latest Go to latest Published: Jan 27, 2017 License: BSD-3-Clause Imports: 13 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/compose/transporter

Links

Open Source Insights

README ¶

etcd adaptor

The etcd adaptor sends data to defined endpoints.

Configuration:

- etcd:
    type: etcd
    uri: 127.0.0.1:5432,127.0.0.1:2345

Documentation ¶

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

This section is empty.

Types ¶

type Config ¶

type Config struct {
	URI       string `json:"uri" doc:"the uri to connect to, in the form TODO"`
	Namespace string `json:"namespace" doc:"mongo namespace to read/write"`
	Timeout   string `json:"timeout" doc:"timeout for establishing connection, format must be parsable by time.ParseDuration and defaults to 10s"`
	Tail      bool   `json:"tail" doc:"if tail is true, then the etcd source will track changes after copying the namespace"`
}

Config provides configuration options for a postgres adaptor the notable difference between this and dbConfig is the presence of the Tail option

type Etcd ¶

type Etcd struct {
	// contains filtered or unexported fields
}

Etcd is an adaptor to read / write to Etcd. it works as a source by copying files, and then optionally watching all keys

func (*Etcd) Connect ¶

func (e *Etcd) Connect() error

func (*Etcd) Description ¶

func (e *Etcd) Description() string

Description for etcd adaptor

func (*Etcd) Listen ¶

func (e *Etcd) Listen() (err error)

Listen starts the pipe's listener

func (*Etcd) SampleConfig ¶

func (e *Etcd) SampleConfig() string

SampleConfig for postgres adaptor

func (*Etcd) Start ¶

func (e *Etcd) Start() (err error)

Start the adaptor as a source

func (*Etcd) Stop ¶

func (e *Etcd) Stop() error

Stop the adaptor

Source Files ¶

View all Source files

etcd.go

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