Documentation
¶
Overview ¶
Copyright The KubeDB Authors.
Licensed under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with the License. You may obtain a copy of the License at
http://www.apache.org/licenses/LICENSE-2.0
Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the specific language governing permissions and limitations under the License.
Copyright The KubeDB Authors.
Licensed under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with the License. You may obtain a copy of the License at
http://www.apache.org/licenses/LICENSE-2.0
Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the specific language governing permissions and limitations under the License.
Copyright The KubeDB Authors.
Licensed under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with the License. You may obtain a copy of the License at
http://www.apache.org/licenses/LICENSE-2.0
Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the specific language governing permissions and limitations under the License.
Copyright The KubeDB Authors.
Licensed under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with the License. You may obtain a copy of the License at
http://www.apache.org/licenses/LICENSE-2.0
Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the specific language governing permissions and limitations under the License.
Copyright The KubeDB Authors.
Licensed under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with the License. You may obtain a copy of the License at
http://www.apache.org/licenses/LICENSE-2.0
Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the specific language governing permissions and limitations under the License.
Index ¶
- func ClusterFailoverCmd(ip string) []string
- func ClusterMeetCmd(senderIP, receiverIP, receiverPort string) []string
- func ClusterNodesCmd(ip string) []string
- func ClusterReplicateCmd(ip, masterNodeID string) []string
- func ClusterResetCmd(ip, resetType string) []string
- func ConfigureRedisCluster(restConfig *rest.Config, redis *api.Redis, version string, pods [][]*core.Pod) error
- func PingCmd(ip string) []string
- type Config
- type RedisCluster
- type RedisNode
- type ResetType
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func ClusterFailoverCmd ¶
func ClusterMeetCmd ¶
func ClusterNodesCmd ¶
******************************************
redis-cli cluster commands (general)
****************************************** https://redis.io/commands/cluster-nodes
func ClusterReplicateCmd ¶
func ClusterResetCmd ¶
func ConfigureRedisCluster ¶
func ConfigureRedisCluster( restConfig *rest.Config, redis *api.Redis, version string, pods [][]*core.Pod) error
ConfigureRedisCluster() configures a cluster. Here, pods[][] contains the ordered pods. pods[i][j] is the j'th Pod of i'th StatefulSet (where each StatefulSet represents a shard. That means if there are 3 shards in cluster, then for each shard there is a StatefulSet and 0'th Pod of i'th StatefulSet is the master for i'th shard and 1, 2, 3, ....'th Pods are the replicas or slaves of that master).
Types ¶
type Config ¶
type Config struct {
// RestConfig is needed to execute commands inside Pods
RestConfig *rest.Config
// Cluster keeps the cluster info
Cluster RedisCluster
// contains filtered or unexported fields
}
Config contains necessary fields that are needed in the processes to configure.
type RedisCluster ¶
type RedisCluster struct {
// Number of master nodes
MasterCnt int
// Number of replica(s) per master node
Replicas int
}
RedisCluster contains same info as `.spec.cluster` of Redis CRD
type RedisNode ¶
type RedisNode struct {
// If this node is a master then it's slots info are stored. Otherwise, these slots info will take the
// default values.
// There is a total of 16384 slots in the cluster. SlotsCnt is the total number of slots, the current
// node contains out of 16384 slots.
// The node may have different ranges of slots. Then SlotStart and SlotEnd are the array of starting and
// ending indices of the range(s) respectively.
// Say, the node has slots of ranges 0-1000 2000-2500 10000-12000.
// So SlotCnt is 3500, SlotStart[] is [0, 2000, 10000] and SlotEnd[] is [1000, 2500 12000]
SlotStart []int
SlotEnd []int
SlotsCnt int
// node id
ID string
// node ip
IP string
// port at which redis server is running in the node
Port int
// node role (either master or slave)
Role string
// true if the flag of the node is 'fail'
Down bool
// If the node role is slave, then Master is set, otherwise it is nil.
Master *RedisNode
// If the node role is master, the Slaves contains the array of it's slave nodes. Otherwise, it is empty.
Slaves []*RedisNode
}
RedisNode stores info about a node
Source Files