nodeutils

Documentation

Index

• type MessageResult
  • func SendMessageToCluster(ctx context.Context, clusterId int64, code string, msg interface{}, ...) (results []*MessageResult, err error)
  • func SendMessageToNodeIds(ctx context.Context, nodeIds []int64, code string, msg interface{}, ...) (results []*MessageResult, err error)

Types

type MessageResult

type MessageResult struct {
	NodeId   int64  `json:"nodeId"`
	NodeName string `json:"nodeName"`
	IsOK     bool   `json:"isOk"`
	Message  string `json:"message"`
}

func SendMessageToCluster

func SendMessageToCluster(ctx context.Context, clusterId int64, code string, msg interface{}, timeoutSeconds int32) (results []*MessageResult, err error)

向集群发送命令消息

func SendMessageToNodeIds

func SendMessageToNodeIds(ctx context.Context, nodeIds []int64, code string, msg interface{}, timeoutSeconds int32) (results []*MessageResult, err error)

向一组节点发送命令消息