coordinator

Documentation

Index

• Constants
• func BackupHandler(c *gin.Context)
• func BackupStatusHandler(c *gin.Context)
• func CancelBackupHandler(c *gin.Context)
• func ConnectToCoordinator(addr string, serviceConn *ServiceConn, lostConnFn func())
• func GetServiceStatusHandler(c *gin.Context)
• func IncidentDetailHandler(c *gin.Context)
• func IncidentSummaryHandler(c *gin.Context)
• func ListBackupsHandler(c *gin.Context)
• func ResetIncidentLogsHandler(c *gin.Context)
• func ServiceRegisterHandler(c *gin.Context)
• func StartCoordinator()
• type CoordinatorCmd
• type CoordinatorState
• type CrashSummary
• type ProgressManager
  • func (pm *ProgressManager) Attach(name string, progressor progress.Progressor)
  • func (pm *ProgressManager) Detach(name string)
  • func (pm *ProgressManager) GetProgressStatus() (int64, int64)
• type ServiceConn

Constants

const (
	ACTION_OPERATION_MODE   = "operationMode"
	ACTION_OPERATION_STATUS = "operationStatus"
)

const (
	SERVICEGROUP_CHAINSYNKER         = "chainsynker"
	SERVICEGROUP_INDEXER             = "indexer"
	SERVICEGROUP_INDEXWORKER         = "indexworker"
	SERVICEGROUP_TRADE_PROCESSOR     = "tradeprocessor"
	SERVICEGROUP_LIQUIDITY_PROCESSOR = "liquidityprocessor"
	SERVICEGROUP_SHIELD_PROCESSOR    = "shieldprocessor"
	SERVICEGROUP_QUERY               = "query"
	SERVICEGROUP_ASSISTANT           = "assistant"
)

Functions

func BackupHandler

func BackupHandler(c *gin.Context)

func BackupStatusHandler

func BackupStatusHandler(c *gin.Context)

func CancelBackupHandler

func CancelBackupHandler(c *gin.Context)

func ConnectToCoordinator

func ConnectToCoordinator(addr string, serviceConn *ServiceConn, lostConnFn func())

func GetServiceStatusHandler

func GetServiceStatusHandler(c *gin.Context)

func IncidentDetailHandler

func IncidentDetailHandler(c *gin.Context)

func IncidentSummaryHandler

func IncidentSummaryHandler(c *gin.Context)

func ListBackupsHandler

func ListBackupsHandler(c *gin.Context)

func ResetIncidentLogsHandler

func ResetIncidentLogsHandler(c *gin.Context)

func ServiceRegisterHandler

func ServiceRegisterHandler(c *gin.Context)

func StartCoordinator

func StartCoordinator()

Types

type CoordinatorCmd

type CoordinatorCmd struct {
	Action string
	Data   string
}

type CoordinatorState

type CoordinatorState struct {
	Detector              *detector.Detector
	ConnectedServicesLock sync.RWMutex
	ConnectedServices     map[string]map[string]*ServiceConn
	// contains filtered or unexported fields
}

type CrashSummary

type CrashSummary struct {
	Total     int
	ByType    map[string]int
	ByService map[string]int
}

type ProgressManager

type ProgressManager struct {
	Progress     map[string]progress.Progressor
	ProgressLock sync.RWMutex
}

func (*ProgressManager) Attach

func (pm *ProgressManager) Attach(name string, progressor progress.Progressor)

func (*ProgressManager) Detach

func (pm *ProgressManager) Detach(name string)

func (*ProgressManager) GetProgressStatus

func (pm *ProgressManager) GetProgressStatus() (int64, int64)

type ServiceConn

type ServiceConn struct {
	ServiceGroup string
	ID           string
	GitCommit    string
	IsPause      bool
	ReadCh       chan []byte
	WriteCh      chan []byte

	ConnectedTime int64
	// contains filtered or unexported fields
}