consul

package

v0.2.3 Latest Latest Go to latest Published: Apr 17, 2016 License: MIT Imports: 2 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
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(cn ConsulKVIFace) stores.StoreIFace
func NewDefault() (stores.StoreIFace, error)
type ConsulKVIFace
type ConsulStore
type MockConsul
- func NewMockConsul(key string, kvb stores.KVBytes, err error) (mc *MockConsul)

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(cn ConsulKVIFace) stores.StoreIFace

func NewDefault ¶

func NewDefault() (stores.StoreIFace, 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 ConsulStore ¶

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

func (*ConsulStore) Delete ¶

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

func (*ConsulStore) Get ¶

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

func (*ConsulStore) List ¶

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

func (*ConsulStore) Set ¶

func (cs *ConsulStore) Set(key string, bts []byte) 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)

Source Files ¶

View all Source files

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