zkcustomrule

Documentation

Index

• Constants
• func ActivateZkCustomRules(qsc tabletserver.Controller)
• type ZkCustomRule
  • func NewZkCustomRule(zkconn zk.Conn) *ZkCustomRule
  • func (zkcr *ZkCustomRule) Close()
  • func (zkcr *ZkCustomRule) GetRules() (qrs *tabletserver.QueryRules, version int64, err error)
  • func (zkcr *ZkCustomRule) Open(qsc tabletserver.Controller, rulePath string) (err error)

Constants

const InvalidQueryRulesVersion int64 = -1

InvalidQueryRulesVersion is used to mark invalid query rules

const ZkCustomRuleSource string = "ZK_CUSTOM_RULE"

ZkCustomRuleSource is zookeeper based custom rule source name

Functions

func ActivateZkCustomRules

func ActivateZkCustomRules(qsc tabletserver.Controller)

ActivateZkCustomRules activates zookeeper dynamic custom rule mechanism

Types

type ZkCustomRule

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

ZkCustomRule is Zookeeper backed implementation of CustomRuleManager

func NewZkCustomRule

func NewZkCustomRule(zkconn zk.Conn) *ZkCustomRule

NewZkCustomRule Creates new ZkCustomRule structure

func (*ZkCustomRule) Close

func (zkcr *ZkCustomRule) Close()

Close signals an termination to polling go routine and closes Zookeeper connection object

func (*ZkCustomRule) GetRules

func (zkcr *ZkCustomRule) GetRules() (qrs *tabletserver.QueryRules, version int64, err error)

GetRules retrives cached rules

func (*ZkCustomRule) Open

func (zkcr *ZkCustomRule) Open(qsc tabletserver.Controller, rulePath string) (err error)

Open Registers Zookeeper watch, gets inital QueryRules and starts polling routine