Method ConfigGet

codis/pkg/proxy/proxy.go:215–332

(key string)

}

func (p *Proxy) ConfigGet(key string) *redis.Resp {
	p.mu.Lock()
	defer p.mu.Unlock()
	switch key {
	case "jodis":
		return redis.NewArray([]*redis.Resp{
			redis.NewBulkBytes([]byte("jodis_name")),
			redis.NewBulkBytes([]byte(p.config.JodisName)),
			redis.NewBulkBytes([]byte("jodis_addr")),
			redis.NewBulkBytes([]byte(p.config.JodisAddr)),
			redis.NewBulkBytes([]byte("jodis_auth")),
			redis.NewBulkBytes([]byte(p.config.JodisAuth)),
			redis.NewBulkBytes([]byte("jodis_timeout")),
			redis.NewBulkBytes([]byte(p.config.JodisTimeout.Duration().String())),
			redis.NewBulkBytes([]byte("jodis_compatible")),
			redis.NewBulkBytes([]byte(strconv.FormatBool(p.config.JodisCompatible))),
		})
	case "proxy":
		return redis.NewArray([]*redis.Resp{
			redis.NewBulkBytes([]byte("proxy_datacenter")),
			redis.NewBulkBytes([]byte(p.config.ProxyDataCenter)),
			redis.NewBulkBytes([]byte("proxy_max_clients")),
			redis.NewBulkBytes([]byte(strconv.Itoa(p.config.ProxyMaxClients))),
			redis.NewBulkBytes([]byte("proxy_max_offheap_size")),
			redis.NewBulkBytes([]byte(p.config.ProxyMaxOffheapBytes.HumanString())),
			redis.NewBulkBytes([]byte("proxy_heap_placeholder")),
			redis.NewBulkBytes([]byte(p.config.ProxyHeapPlaceholder.HumanString())),
		})
	case "backend_ping_period":
		return redis.NewBulkBytes([]byte(p.config.BackendPingPeriod.Duration().String()))
	case "backend_buffer_size":
		return redis.NewArray([]*redis.Resp{
			redis.NewBulkBytes([]byte("backend_recv_bufsize")),
			redis.NewBulkBytes([]byte(p.config.BackendRecvBufsize.HumanString())),
			redis.NewBulkBytes([]byte("backend_send_bufsize")),
			redis.NewBulkBytes([]byte(p.config.BackendSendBufsize.HumanString())),
		})
	case "backend_timeout":
		return redis.NewArray([]*redis.Resp{
			redis.NewBulkBytes([]byte("backend_recv_timeout")),
			redis.NewBulkBytes([]byte(p.config.BackendRecvTimeout.Duration().String())),
			redis.NewBulkBytes([]byte("backend_send_timeout")),
			redis.NewBulkBytes([]byte(p.config.BackendSendTimeout.Duration().String())),
		})
	case "backend_max_pipeline":
		return redis.NewBulkBytes([]byte(strconv.Itoa(p.config.BackendMaxPipeline)))
	case "backend_primary_only":
		return redis.NewBulkBytes([]byte(strconv.FormatBool(p.config.BackendPrimaryOnly)))
	case "max_slot_num":
		return redis.NewBulkBytes([]byte(strconv.Itoa(p.config.MaxSlotNum)))
	case "backend_primary_parallel":
		return redis.NewBulkBytes([]byte(strconv.Itoa(p.config.BackendPrimaryParallel)))
	case "backend_replica_parallel":
		return redis.NewBulkBytes([]byte(strconv.Itoa(p.config.BackendReplicaParallel)))
	case "backend_primary_quick":
		return redis.NewBulkBytes([]byte(strconv.Itoa(p.config.BackendPrimaryQuick)))
	case "backend_replica_quick":
		return redis.NewBulkBytes([]byte(strconv.Itoa(p.config.BackendReplicaQuick)))