type github.com/go-redis/redis/v8.clusterNode
51 uses
github.com/go-redis/redis/v8 (current package)
cluster.go#L164: type clusterNode struct {
cluster.go#L172: func newClusterNode(clOpt *ClusterOptions, addr string) *clusterNode {
cluster.go#L175: node := clusterNode{
cluster.go#L187: func (n *clusterNode) String() string {
cluster.go#L191: func (n *clusterNode) Close() error {
cluster.go#L195: func (n *clusterNode) updateLatency() {
cluster.go#L211: func (n *clusterNode) Latency() time.Duration {
cluster.go#L216: func (n *clusterNode) MarkAsFailing() {
cluster.go#L220: func (n *clusterNode) Failing() bool {
cluster.go#L234: func (n *clusterNode) Generation() uint32 {
cluster.go#L238: func (n *clusterNode) SetGeneration(gen uint32) {
cluster.go#L254: nodes map[string]*clusterNode
cluster.go#L266: nodes: make(map[string]*clusterNode),
cluster.go#L321: var collected []*clusterNode
cluster.go#L346: func (c *clusterNodes) Get(addr string) (*clusterNode, error) {
cluster.go#L375: func (c *clusterNodes) get(addr string) (*clusterNode, error) {
cluster.go#L376: var node *clusterNode
cluster.go#L388: func (c *clusterNodes) All() ([]*clusterNode, error) {
cluster.go#L396: cp := make([]*clusterNode, 0, len(c.nodes))
cluster.go#L403: func (c *clusterNodes) Random() (*clusterNode, error) {
cluster.go#L417: nodes []*clusterNode
cluster.go#L436: Masters []*clusterNode
cluster.go#L437: Slaves []*clusterNode
cluster.go#L461: var nodes []*clusterNode
cluster.go#L526: func (c *clusterState) slotMasterNode(slot int) (*clusterNode, error) {
cluster.go#L534: func (c *clusterState) slotSlaveNode(slot int) (*clusterNode, error) {
cluster.go#L547: var slave *clusterNode
cluster.go#L561: func (c *clusterState) slotClosestNode(slot int) (*clusterNode, error) {
cluster.go#L567: var node *clusterNode
cluster.go#L584: func (c *clusterState) slotRandomNode(slot int) (*clusterNode, error) {
cluster.go#L593: func (c *clusterState) slotNodes(slot int) []*clusterNode {
cluster.go#L766: var node *clusterNode
cluster.go#L859: go func(node *clusterNode) {
cluster.go#L897: go func(node *clusterNode) {
cluster.go#L933: worker := func(node *clusterNode) {
cluster.go#L1106: go func(node *clusterNode, cmds []Cmder) {
cluster.go#L1173: ctx context.Context, node *clusterNode, cmds []Cmder, failedCmds *cmdsMap,
cluster.go#L1193: node *clusterNode,
cluster.go#L1279: cmdsMap := map[*clusterNode][]Cmder{node: cmds}
cluster.go#L1293: go func(node *clusterNode, cmds []Cmder) {
cluster.go#L1331: ctx context.Context, node *clusterNode, cmds []Cmder, failedCmds *cmdsMap,
cluster.go#L1493: var node *clusterNode
cluster.go#L1634: ) (*clusterNode, error) {
cluster.go#L1646: func (c *clusterClient) slotReadOnlyNode(state *clusterState, slot int) (*clusterNode, error) {
cluster.go#L1656: func (c *ClusterClient) slotMasterNode(ctx context.Context, slot int) (*clusterNode, error) {
cluster.go#L1664: func appendUniqueNode(nodes []*clusterNode, node *clusterNode) []*clusterNode {
cluster.go#L1690: m map[*clusterNode][]Cmder
cluster.go#L1695: m: make(map[*clusterNode][]Cmder),
cluster.go#L1699: func (m *cmdsMap) Add(node *clusterNode, cmds ...Cmder) {
 |
The pages are generated with Golds v0.3.2-preview. (GOOS=darwin GOARCH=amd64)
Golds is a Go 101 project developed by Tapir Liu.
PR and bug reports are welcome and can be submitted to the issue list.
Please follow @Go100and1 (reachable from the left QR code) to get the latest news of Golds. |