Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type MewldDiagPayload ¶
type MewldDiagResponse ¶
type MewldDiagResponse struct { ClusterID uint16 `json:"cluster_id"` Nonce string `json:"Nonce"` Data []MewldDiagShardHealth `json:"Data"` }
type MewldDiagShardHealth ¶
type MewldResponder ¶
type MewldResponder struct { ClusterID uint16 ClusterName string Shards []uint16 Channel string OnDiag func(p *MewldDiagPayload) (*MewldDiagResponse, error) OnAllClustersLaunched func() error OnLaunchNext func() error OnLauncherCmd func(cmd mredis.LauncherCmd) error }
func (*MewldResponder) LaunchNext ¶
Sends the launch_next command
func (*MewldResponder) Listen ¶
Listen starts listening for messages from redis and restarts the listener if it dies
func (*MewldResponder) ListenOnce ¶
ListenOnce starts listening for messages from redis
This is *blocking* and should be run in a goroutine
Click to show internal directories.
Click to hide internal directories.