remote

package

v0.2.0 Latest Latest Go to latest Published: Nov 11, 2019 License: BSD-3-Clause Imports: 11 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

type Decoder interface {
	Decode(io.Reader) (interface{}, error)
}

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

func (p *EtcdV3) Get(rp lung.RemoteProvider) (io.Reader, error)

func (p *EtcdV3) Watch(rp lung.RemoteProvider) (io.Reader, error)

func (p *EtcdV3) WatchChannel(rp lung.RemoteProvider) (<-chan *lung.RemoteResponse, chan bool)

type Etcdv2 struct {
	Decoder
	lung.RemoteProvider

	Username string
	Password string
}

func (c *Etcdv2) Get(rp lung.RemoteProvider) (io.Reader, error)

func (c *Etcdv2) Watch(rp lung.RemoteProvider) (io.Reader, error)

func (c *Etcdv2) WatchChannel(rp lung.RemoteProvider) (<-chan *lung.RemoteResponse, chan bool)