fleet

type Accept struct {
	Round    int64  `json:"round"` // multipaxos round number
	AcceptId int64  `json:"acceptId"`
	NodeId   int64  `json:"nodeId"` // tie-breaker
	Value    string `json:"value"`
}

type Accepted struct {
	Error    error `json:"error"` // non-nil = NACK
	Round    int64 `json:"round"` // multipaxos round number
	AcceptId int64 `json:"acceptId"`
	NodeId   int64 `json:"nodeId"` // tie-breaker
}

type FleetData struct {
	App *appdata.AppData // global appdata

	StateMachine *rsmT // our replicated state machine

	BuildRsmWip *timedoff.TimedOff // pause ops when active
	BuildRsmOn  int64              // non-zero means someone is rebuilding their RSM

	Online int32 // non-zero mean we are ready to serve

	SetValueMtx       sync.RWMutex
	SetValueHistory   map[int]*SetValueHistoryT // track incoming rounds since online, not complete
	SetValueLastRound int64
	SetValueReady     int32
	// contains filtered or unexported fields
}

type LearnValuesInput struct {
	Rounds []int `json:"rounds"`
}

type LearnValuesOutput struct {
	Value Accept `json:"value"` // reuse
}

type LockState struct {
	Name     string
	Token    string
	State    int32     // 1 = locked, > 1 = extended, 0 = available|released
	Start    time.Time // should be Spanner time, not local
	Duration int64     // seconds
	Error    error
}

type MetaT struct {
	Id        string    `json:"id"`
	Round     int64     `json:"round"`
	Value     string    `json:"value"`
	Updated   time.Time `json:"updated"`
	Committed time.Time `json:"committed"`
}

type Prepare struct {
	PrepareId int64 `json:"prepareId"` // proposal
	NodeId    int64 `json:"nodeId"`    // tie-breaker
	Round     int64 `json:"round"`     // multipaxos round number
}

type Promise struct {
	Error          error  `json:"error"`     // non-nil = NACK
	PrepareId      int64  `json:"prepareId"` // proposal
	NodeId         int64  `json:"nodeId"`    // tie-breaker
	Round          int64  `json:"round"`     // multipaxos round number
	LastPrepareId  int64  `json:"lastPrepareId"`
	LastAcceptedId int64  `json:"lastAcceptedId"`
	Value          string `json:"value"`
}

type ReachConsensusInput struct {
	FleetData *FleetData `json:"fd,omitempty"`
	CmdType   string     `json:"cmdType,omitempty"`
	Key       string     `json:"key,omitempty"`
	Value     string     `json:"value,omitempty"`
	// contains filtered or unexported fields
}

type ReachConsensusOutput struct {
	Round int64  `json:"round,omitempty"`
	Key   string `json:"key,omitempty"`
	Value string `json:"value,omitempty"`
}

type SendToLeaderExtra struct {
	RetryCount int
	BackOff    *gaxv2.Backoff // use if non-nil
}

type SetValueHistoryT struct {
	Value   string
	Applied bool
}