• Home
  • History
  • Annotate
  • Raw
  • Download
  • only in /5.5.2/goproj/src/github.com/couchbase/indexing/secondary/manager/

Lines Matching defs:key

167 func (c *MetadataRepo) SetLocalValue(key string, value string) error {
171 return c.repo.setLocalValue(key, value)
174 func (c *MetadataRepo) DeleteLocalValue(key string) error {
178 return c.repo.deleteLocalValue(key)
181 func (c *MetadataRepo) GetLocalValue(key string) (string, error) {
185 return c.repo.getLocalValue(key)
530 key, content, err := iter.Next()
535 if isIndexDefnKey(key) {
536 id := indexDefnIdFromKey(key)
558 key, content, err := iter.Next()
563 if isIndexTopologyKey(key) {
569 bucket := getBucketFromTopologyKey(key)
709 func getEventType(key string) EventType {
712 metaType := findTypeFromKey(key)
726 func (c *LocalRepoRef) setLocalValue(key string, value string) error {
727 return c.server.SetConfigValue(key, value)
730 func (c *LocalRepoRef) deleteLocalValue(key string) error {
731 return c.server.DeleteConfigValue(key)
734 func (c *LocalRepoRef) getLocalValue(key string) (string, error) {
735 return c.server.GetConfigValue(key)
790 logging.Debugf("RemoteRepoRef.getMeta(): Found metadata in local repository for key %s", name)
798 logging.Debugf("RemoteRepoRef.getMeta(): key=%s", name)
813 logging.Debugf("RemoteRepoRef.getMeta(): remote metadata for key %s exist=%v", name, reply != nil && reply.Result != nil)
887 func (c *RemoteRepoRef) setLocalValue(key string, value string) error {
891 func (c *RemoteRepoRef) deleteLocalValue(key string) error {
895 func (c *RemoteRepoRef) getLocalValue(key string) (string, error) {
919 func findTypeFromKey(key string) MetadataKind {
921 if isIndexDefnKey(key) {
923 } else if isIndexTopologyKey(key) {
925 } else if isGlobalTopologyKey(key) {
939 func indexDefnId(key string) (common.IndexDefnId, error) {
940 val, err := strconv.ParseUint(key, 10, 64)
951 func isIndexDefnKey(key string) bool {
952 return strings.Contains(key, "IndexDefinitionId/")
955 func indexDefnIdFromKey(key string) string {
957 i := strings.Index(key, "IndexDefinitionId/")
959 return key[i+len("IndexDefinitionId/"):]
973 func getBucketFromTopologyKey(key string) string {
974 i := strings.Index(key, "IndexTopology/")
976 return key[i+len("IndexTopology/"):]
982 func isIndexTopologyKey(key string) bool {
983 return strings.Contains(key, "IndexTopology/")
1010 func isGlobalTopologyKey(key string) bool {
1011 return strings.Contains(key, "GlobalIndexTopology")
1042 func isServiceMap(key string) bool {
1043 return strings.Contains(key, "ServiceMap")
1050 func isIndexStats(key string) bool {
1051 return strings.Contains(key, "IndexStats")
1290 func (m *LocalRepoRef) OnNewProposal(txnid c.Txnid, op c.OpCode, key string, content []byte) error {
1296 logging.Debugf("LocalRepoRef.OnNewProposal(): key %s", key)
1300 if isIndexDefnKey(key) {
1301 return m.onNewProposalForCreateIndexDefn(txnid, op, key, content)
1305 if isIndexDefnKey(key) {
1306 return m.onNewProposalForCreateIndexDefn(txnid, op, key, content)
1310 if isIndexDefnKey(key) {
1311 return m.onNewProposalForDeleteIndexDefn(txnid, op, key, content)
1318 func (m *LocalRepoRef) OnCommit(txnid c.Txnid, key string) {
1322 func (m *LocalRepoRef) onNewProposalForCreateIndexDefn(txnid c.Txnid, op c.OpCode, key string, content []byte) error {
1324 logging.Debugf("LocalRepoRef.OnNewProposalForCreateIndexDefn(): key %s", key)
1328 logging.Debugf("LocalRepoRef.OnNewProposalForCreateIndexDefn(): fail to unmarshall index defn for key %s", key)
1339 func (m *LocalRepoRef) onNewProposalForDeleteIndexDefn(txnid c.Txnid, op c.OpCode, key string, content []byte) error {
1341 logging.Debugf("LocalRepoRef.OnNewProposalForDeleteIndexDefn(): key %s", key)
1343 i := strings.Index(key, "/")
1344 if i != -1 && i < len(key)-1 {
1346 id, err := strconv.ParseUint(key[i+1:], 10, 64)
1348 logging.Debugf("LocalRepoRef.OnNewProposalForDeleteIndexDefn(): fail to unmarshall IndexDefnId key %s", key)
1358 logging.Debugf("LocalRepoRef.OnNewProposalForDeleteIndexDefn(): fail to unmarshall IndexDefnId key %s", key)