instanceinfosync

Documentation

Index

• Variables
• func InstancestatusStateMachine(currentStatus, expectNextStatus instanceinfo.InstancePhase) (resultStatus instanceinfo.InstancePhase)
• type MetaserverMSG
• type Syncer
  • func NewSyncer(db *instanceinfo.Client) *Syncer
  • func (s *Syncer) Sync()

Variables

var MsgTimeout = 3 * time.Minute

Functions

func InstancestatusStateMachine

func InstancestatusStateMachine(currentStatus,
	expectNextStatus instanceinfo.InstancePhase) (resultStatus instanceinfo.InstancePhase)

Types

type MetaserverMSG

type MetaserverMSG struct {
	Name      string                 `json:"name"`      // metaserver_container、metaserver_all_containers
	TimeStamp int64                  `json:"timestamp"` // Nanosecond
	Fields    map[string]interface{} `json:"fields"`    // Full container event key: containerID value: container info
	Tags      map[string]string      `json:"tags,omitempty"`
}

MetaserverMSG kafka format of container message

type Syncer

type Syncer struct {
	// contains filtered or unexported fields
}

func NewSyncer

func NewSyncer(db *instanceinfo.Client) *Syncer

func (*Syncer) Sync

func (s *Syncer) Sync()