cache

Documentation

Index

• type Meta
• type MetaMap
  • func (c *MetaMap) Add(obj v1beta2.Emqx)
  • func (c *MetaMap) Cache(obj v1beta2.Emqx) *Meta
  • func (c *MetaMap) Del(obj metav1.Object)
  • func (c *MetaMap) Get(obj metav1.Object) *Meta
  • func (c *MetaMap) Update(meta *Meta, new v1beta2.Emqx)
• type StateType

Types

type Meta

type Meta struct {
	NameSpace string
	Name      string
	State     StateType
	Size      int32
	Obj       v1beta2.Emqx

	Status  v1beta2.ConditionType
	Message string

	Config map[string]string
}

Meta contains EMQX Cluster some metadata

type MetaMap

type MetaMap struct {
	sync.Map
}

MetaMap cache last EMQX Cluster and meta data

func (*MetaMap) Add

func (c *MetaMap) Add(obj v1beta2.Emqx)

func (*MetaMap) Cache

func (c *MetaMap) Cache(obj v1beta2.Emqx) *Meta

func (*MetaMap) Del

func (c *MetaMap) Del(obj metav1.Object)

func (*MetaMap) Get

func (c *MetaMap) Get(obj metav1.Object) *Meta

func (*MetaMap) Update

func (c *MetaMap) Update(meta *Meta, new v1beta2.Emqx)

type StateType

type StateType string

const (
	Create StateType = "create"
	Update StateType = "update"
	Check  StateType = "check"
)