api

Documentation

Index

• Constants
• Variables
• func KeyNotFoundError(n string) error
• type Client
  • func New(st stores.IFace, rp repo.IFace, cfg *config.Config, stats *godspeed.Godspeed) (c *Client)
  • func (c *Client) Commit(ft *models.Feature, deleted bool) error
  • func (c *Client) Delete(key string, scope string) error
  • func (c *Client) Get(key string, v interface{}) error
  • func (c *Client) GetInfo() (*models.Info, error)
  • func (c *Client) InitRepo(create bool) error
  • func (c *Client) KVsToFeatureMap(kvb stores.KVBytes) (*models.FeatureMap, error)
  • func (c *Client) List(prefix string, scope string) (models.Features, error)
  • func (c *Client) Namespace() string
  • func (c *Client) Push() error
  • func (c *Client) SendStatEvent(f *models.Feature, delete bool) error
  • func (c *Client) Set(ft *models.Feature) error
  • func (c *Client) UpdateCurrentSHA() (string, error)
  • func (c *Client) Watch()
  • func (c *Client) WriteOutputFile(kvb stores.KVBytes)
• type ClientIFace

Constants

const InfoNameSpace = "info"

Variables

var ErrNilValue = errors.New("value cannot be nil")

var ErrRepoExists = errors.New("repository already exists")

var ErrTypeChange = errors.New("cannot change existing feature types")

Functions

func KeyNotFoundError

func KeyNotFoundError(n string) error

Types

type Client

type Client struct {
	Store stores.IFace
	Repo  repo.IFace
	Stats *godspeed.Godspeed
	// contains filtered or unexported fields
}

func New

func New(st stores.IFace, rp repo.IFace, cfg *config.Config, stats *godspeed.Godspeed) (c *Client)

func (*Client) Commit

func (c *Client) Commit(ft *models.Feature, deleted bool) error

func (*Client) Delete

func (c *Client) Delete(key string, scope string) error

func (*Client) Get

func (c *Client) Get(key string, v interface{}) error

func (*Client) GetInfo

func (c *Client) GetInfo() (*models.Info, error)

func (*Client) InitRepo

func (c *Client) InitRepo(create bool) error

func (*Client) KVsToFeatureMap

func (c *Client) KVsToFeatureMap(kvb stores.KVBytes) (*models.FeatureMap, error)

KVsToFeatures helper for unmarshalling `KVBytes` to a `FeatureMap`

func (*Client) List

func (c *Client) List(prefix string, scope string) (models.Features, error)

func (*Client) Namespace

func (c *Client) Namespace() string

func (*Client) Push

func (c *Client) Push() error

func (*Client) SendStatEvent

func (c *Client) SendStatEvent(f *models.Feature, delete bool) error

func (*Client) Set

func (c *Client) Set(ft *models.Feature) error

func (*Client) UpdateCurrentSHA

func (c *Client) UpdateCurrentSHA() (string, error)

func (*Client) Watch

func (c *Client) Watch()

func (*Client) WriteOutputFile

func (c *Client) WriteOutputFile(kvb stores.KVBytes)

type ClientIFace

type ClientIFace interface {
	List(prefix string, scope string) (models.Features, error)
	Set(ft *models.Feature) error
	Get(key string, v interface{}) error
	Delete(key string, scope string) error
	GetInfo() (*models.Info, error)
	InitRepo(create bool) error
	Commit(ft *models.Feature, deleted bool) error
	Push() error
	UpdateCurrentSHA() (string, error)
	Watch()
	Namespace() string
}