consul

package

v0.3.4 Latest Latest Go to latest Published: Mar 16, 2021 License: MIT Imports: 5 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/vsco/dcdr

Links

Open Source Insights

Documentation ¶

Index ¶

func KvPairsToKvBytes(kvp api.KVPairs) (stores.KVBytes, error)
func New(cfg *config.Config, cn ConsulKVIFace) stores.IFace
func NewDefault(cfg *config.Config) (stores.IFace, error)
type ConsulKVIFace
type MockConsul
- func NewMockConsul(key string, kvb stores.KVBytes, err error) (mc *MockConsul)
type Store

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

func KvPairsToKvBytes ¶

func KvPairsToKvBytes(kvp api.KVPairs) (stores.KVBytes, error)

func New ¶

func New(cfg *config.Config, cn ConsulKVIFace) stores.IFace

func NewDefault ¶

func NewDefault(cfg *config.Config) (stores.IFace, error)

Types ¶

type ConsulKVIFace ¶

type ConsulKVIFace interface {
	List(prefix string, q *api.QueryOptions) (api.KVPairs, *api.QueryMeta, error)
	Get(key string, q *api.QueryOptions) (*api.KVPair, *api.QueryMeta, error)
	Put(p *api.KVPair, q *api.WriteOptions) (*api.WriteMeta, error)
	Delete(key string, w *api.WriteOptions) (*api.WriteMeta, error)
}

type MockConsul ¶

type MockConsul struct {
	Item  *stores.KVByte
	Items stores.KVBytes
	Err   error
}

func NewMockConsul ¶

func NewMockConsul(key string, kvb stores.KVBytes, err error) (mc *MockConsul)

func (*MockConsul) Delete ¶

func (mc *MockConsul) Delete(key string, w *api.WriteOptions) (*api.WriteMeta, error)

func (*MockConsul) Get ¶

func (mc *MockConsul) Get(key string, qo *api.QueryOptions) (*api.KVPair, *api.QueryMeta, error)

func (*MockConsul) List ¶

func (mc *MockConsul) List(prefix string, qo *api.QueryOptions) (api.KVPairs, *api.QueryMeta, error)

func (*MockConsul) Put ¶

func (mc *MockConsul) Put(p *api.KVPair, qo *api.WriteOptions) (*api.WriteMeta, error)

type Store ¶ added in v0.2.4

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

func (*Store) Close ¶ added in v0.2.4

func (s *Store) Close()

func (*Store) Delete ¶ added in v0.2.4

func (cs *Store) Delete(key string) error

func (*Store) Get ¶ added in v0.2.4

func (cs *Store) Get(key string) (*stores.KVByte, error)

func (*Store) List ¶ added in v0.2.4

func (cs *Store) List(prefix string) (stores.KVBytes, error)

func (*Store) Register ¶ added in v0.2.4

func (cs *Store) Register(cb func(kvb stores.KVBytes))

func (*Store) Set ¶ added in v0.2.4

func (cs *Store) Set(key string, bts []byte) error

func (*Store) Updated ¶ added in v0.2.4

func (cs *Store) Updated(kvs interface{})

func (*Store) Watch ¶ added in v0.2.4

func (cs *Store) Watch() error

Source Files ¶

View all Source files

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