store

Documentation

Index

• Constants
• func PodObjectIndexFuncFactory(fieldCategory, fieldName string) cache.IndexFunc
• type KStore
  • func New(client clientset.Interface, httpBind, raftBind, raftDir, join string) *KStore
  • func (ks *KStore) GetCacheAsJson() (string, error)
  • func (ks *KStore) GetCacheByIndex(indexName, indexKey string) (string, error)
  • func (ks *KStore) GetCacheByMultipleIndex(indexKV map[string][]string) (string, error)
  • func (ks *KStore) GetIndiceByName(indexName string) ([]string, error)
  • func (ks *KStore) Join(nodeID, addr string) error
  • func (ks *KStore) Reset(data *map[string]*cache.ObjectDef) error
  • func (ks *KStore) ServeHttp()
  • func (ks *KStore) Start(enableSingleNode bool, localID string)
  • func (ks *KStore) Stop()
  • func (ks *KStore) Stopped() bool
  • func (ks *KStore) WaitUtilStop()

Constants

const (
	DeleteCategory = "delete"
	Deleted        = "true"
	NonDeleted     = "false"
)

const (
	ObjectTypePods = "pods"
)

Functions

func PodObjectIndexFuncFactory

func PodObjectIndexFuncFactory(fieldCategory, fieldName string) cache.IndexFunc

make a factory to produce indexFunc for those regular field category, such as meta, spec, status etc. fieldName is a helper while we can NOT determine the key via fieldCategory.

Types

type KStore

type KStore struct {

	// raft and consensus mechanism
	RaftDir, RaftBind, JoinAddr string // TODO: ensure dir exists.

	// http server configurations
	HttpBind string
	// contains filtered or unexported fields
}

func New

func New(client clientset.Interface, httpBind, raftBind, raftDir, join string) *KStore

func (*KStore) GetCacheAsJson

func (ks *KStore) GetCacheAsJson() (string, error)

func (*KStore) GetCacheByIndex

func (ks *KStore) GetCacheByIndex(indexName, indexKey string) (string, error)

func (*KStore) GetCacheByMultipleIndex

func (ks *KStore) GetCacheByMultipleIndex(indexKV map[string][]string) (string, error)

func (*KStore) GetIndiceByName

func (ks *KStore) GetIndiceByName(indexName string) ([]string, error)

func (*KStore) Join

func (ks *KStore) Join(nodeID, addr string) error

Join do raft peer join(ONLY leader can do this)

func (*KStore) Reset

func (ks *KStore) Reset(data *map[string]*cache.ObjectDef) error

func (*KStore) ServeHttp

func (ks *KStore) ServeHttp()

func (*KStore) Start

func (ks *KStore) Start(enableSingleNode bool, localID string)

func (*KStore) Stop

func (ks *KStore) Stop()

func (*KStore) Stopped

func (ks *KStore) Stopped() bool

func (*KStore) WaitUtilStop

func (ks *KStore) WaitUtilStop()