node

type Agent struct {
	*meta.StateMachine[string]
	// contains filtered or unexported fields
}

type AgentConfManager interface {
	GetConf() *Conf
	SaveConf(c *Conf) error
	NeedProvision() bool
	UpdateProvision(id string, expire uint64) bool
}

type AgentOption func(agent *Agent)

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

type AgentSideCallback func()

type AgentSideHooks struct {
	//called after initialized
	OnInitialized AgentSideCallback

	//called after successfully authed
	OnAuthenticated AgentSideCallback

	//called when preparing or re-preparing finished
	OnMaintained AgentSideCallback

	//called when stream message received
	OnServerNasMsg func(*StreamMessage)

	//called after stopped
	OnStopped AgentSideCallback
}

type AppendReq struct {
	Term         uint64        //leader’s term
	LeaderID     string        //leader id so follower can redirect clients
	PrevLogIndex uint64        //index of log entry immediately preceding new ones
	PrevLogTerm  uint64        //term of prevLogIndex entry
	Entries      []interface{} //log entries to store (empty for heartbeat; may send more than one for efficiency)
	LeaderCommit uint64        // leader’s commitIndex
}

type AppendRsp struct {
	Term    uint64 //currentTerm, for leader to update itself
	Success bool   //true if follower contained entry matching prevLogIndex and prevLogTerm
}

type CheckUpgradeReq struct {
	VersionInfo          *VersionInfo `protobuf:"bytes,1,opt,name=versionInfo,proto3" json:"versionInfo,omitempty"`
	XXX_NoUnkeyedLiteral struct{}     `json:"-"`
	XXX_unrecognized     []byte       `json:"-"`
	XXX_sizecache        int32        `json:"-"`
}

type CheckUpgradeRsp struct {
	UpgradeInfo          *UpgradeInfo `protobuf:"bytes,1,opt,name=upgradeInfo,proto3" json:"upgradeInfo,omitempty"`
	XXX_NoUnkeyedLiteral struct{}     `json:"-"`
	XXX_unrecognized     []byte       `json:"-"`
	XXX_sizecache        int32        `json:"-"`
}

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

type Conf struct {
	Identity       string `json:"identity"`       //identity of current agent
	ExpirationTime int64  `json:"expirationTime"` //current provision expiration time
	ProvisionTime  int64  `json:"provisionTime"`  //initial provision timestamp
	LastUpdateTime int64  `json:"lastUpdateTime"` //timestamp when recent update of provision info
	RepeatTimes    uint32 `json:"repeatTimes"`    // number of times re-provisioned
}

type DeviceInfo struct {
	Type                 uint32   `protobuf:"varint,1,opt,name=type,proto3" json:"type,omitempty"`
	Vendor               string   `protobuf:"bytes,2,opt,name=vendor,proto3" json:"vendor,omitempty"`
	Model                string   `protobuf:"bytes,3,opt,name=model,proto3" json:"model,omitempty"`
	Version              string   `protobuf:"bytes,4,opt,name=version,proto3" json:"version,omitempty"`
	CpuInfo              string   `protobuf:"bytes,7,opt,name=cpuInfo,proto3" json:"cpuInfo,omitempty"`
	MemInfo              uint64   `protobuf:"varint,8,opt,name=memInfo,proto3" json:"memInfo,omitempty"`
	Storage              uint64   `protobuf:"varint,9,opt,name=storage,proto3" json:"storage,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

type ElectionService interface {
	RequestVote(req *VoteReq, rsp *VoteRsp) error
	IncrementTerm()
	VoteForMySelf()
	BroadcastVote()
	WinTheElection() bool
}

type ErrorCode int32

type GetConfigReq struct {
	ParameterInfo        *ParameterInfo `protobuf:"bytes,1,opt,name=parameterInfo,proto3" json:"parameterInfo,omitempty"`
	XXX_NoUnkeyedLiteral struct{}       `json:"-"`
	XXX_unrecognized     []byte         `json:"-"`
	XXX_sizecache        int32          `json:"-"`
}

type GetConfigRsp struct {
	ParameterInfo        *ParameterInfo `protobuf:"bytes,1,opt,name=parameterInfo,proto3" json:"parameterInfo,omitempty"`
	XXX_NoUnkeyedLiteral struct{}       `json:"-"`
	XXX_unrecognized     []byte         `json:"-"`
	XXX_sizecache        int32          `json:"-"`
}

type Node struct {
	Identity   string `json:"identity"`   //identity of a node
	Status     uint32 `json:"status"`     //node status
	Endpoint   string `json:"endpoint"`   //current endpoint address
	ExpireTime uint64 `json:"expireTime"` //identity expiration time, in seconds
	SignUpTime uint64 `json:"signUpTime"` //sign up timestamp, in seconds
	SignInTime uint64 `json:"signInTime"` //sign in timestamp, in seconds
	UpdateTime uint64 `json:"updateTime"` //timestamp when recent update of provision info
}

type ParameterInfo struct {
	// parameter name - value
	Parameters           map[string]*ParameterInfo_Parameter `` /* 161-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{}                            `json:"-"`
	XXX_unrecognized     []byte                              `json:"-"`
	XXX_sizecache        int32                               `json:"-"`
}

type ParameterInfo_Parameter struct {
	Type                 string   `protobuf:"bytes,1,opt,name=type,proto3" json:"type,omitempty"`
	Value                string   `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

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

type Procedure int32

type RaftRole string

type RaftService interface {
	ReplicationService
	ElectionService
}

type ReplicationService interface {
	AppendEntries(req *AppendReq, rsp *AppendRsp) error
}

type ReportStatusReq struct {
	SoftwareVersion      string         `protobuf:"bytes,1,opt,name=softwareVersion,proto3" json:"softwareVersion,omitempty"`
	ProtocolVersion      string         `protobuf:"bytes,2,opt,name=protocolVersion,proto3" json:"protocolVersion,omitempty"`
	Ipv4Address          string         `protobuf:"bytes,3,opt,name=ipv4Address,proto3" json:"ipv4Address,omitempty"`
	DeviceInfo           *DeviceInfo    `protobuf:"bytes,11,opt,name=deviceInfo,proto3" json:"deviceInfo,omitempty"`
	Utilization          *Utilization   `protobuf:"bytes,12,opt,name=utilization,proto3" json:"utilization,omitempty"`
	VersionInfo          *VersionInfo   `protobuf:"bytes,13,opt,name=versionInfo,proto3" json:"versionInfo,omitempty"`
	ParameterInfo        *ParameterInfo `protobuf:"bytes,14,opt,name=parameterInfo,proto3" json:"parameterInfo,omitempty"`
	XXX_NoUnkeyedLiteral struct{}       `json:"-"`
	XXX_unrecognized     []byte         `json:"-"`
	XXX_sizecache        int32          `json:"-"`
}

type S1ServiceClient interface {
	// agent-initiated unidirectional services
	SignUp(ctx context.Context, in *SignUpReq, opts ...grpc.CallOption) (*SignUpRsp, error)
	SignIn(ctx context.Context, in *SignInReq, opts ...grpc.CallOption) (*SignInRsp, error)
	SignOut(ctx context.Context, in *SignOutReq, opts ...grpc.CallOption) (*SignOutRsp, error)
	Report(ctx context.Context, in *ReportStatusReq, opts ...grpc.CallOption) (*empty.Empty, error)
	Config(ctx context.Context, in *GetConfigReq, opts ...grpc.CallOption) (*GetConfigRsp, error)
	// agent-initiated bidirectional service
	StreamTransfer(ctx context.Context, opts ...grpc.CallOption) (S1Service_StreamTransferClient, error)
}

type S1ServiceServer interface {
	// agent-initiated unidirectional services
	SignUp(context.Context, *SignUpReq) (*SignUpRsp, error)
	SignIn(context.Context, *SignInReq) (*SignInRsp, error)
	SignOut(context.Context, *SignOutReq) (*SignOutRsp, error)
	Report(context.Context, *ReportStatusReq) (*empty.Empty, error)
	Config(context.Context, *GetConfigReq) (*GetConfigRsp, error)
	// agent-initiated bidirectional service
	StreamTransfer(S1Service_StreamTransferServer) error
}

type S1Service_StreamTransferClient interface {
	Send(*StreamMessage) error
	Recv() (*StreamMessage, error)
	grpc.ClientStream
}

type S1Service_StreamTransferServer interface {
	Send(*StreamMessage) error
	Recv() (*StreamMessage, error)
	grpc.ServerStream
}

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

type ServerConfManager interface {
	GetNode(id string) *Node
	SaveNode(n *Node) error
}

type ServerOption func(agent *Server)

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

type ServerSideCallback func(*Node)

type ServerSideHooks struct {
	//called when a certain node is successfully authed
	OnNodeJoin ServerSideCallback

	//called when stream message received
	OnNodeNasMsg func(*StreamMessage)

	//called when a certain node checked out
	OnNodeLeave ServerSideCallback
}

type SignInReq struct {
	SoftwareVersion      string         `protobuf:"bytes,1,opt,name=softwareVersion,proto3" json:"softwareVersion,omitempty"`
	ProtocolVersion      string         `protobuf:"bytes,2,opt,name=protocolVersion,proto3" json:"protocolVersion,omitempty"`
	Ipv4Address          string         `protobuf:"bytes,3,opt,name=ipv4Address,proto3" json:"ipv4Address,omitempty"`
	DeviceInfo           *DeviceInfo    `protobuf:"bytes,11,opt,name=deviceInfo,proto3" json:"deviceInfo,omitempty"`
	Utilization          *Utilization   `protobuf:"bytes,12,opt,name=utilization,proto3" json:"utilization,omitempty"`
	VersionInfo          *VersionInfo   `protobuf:"bytes,13,opt,name=versionInfo,proto3" json:"versionInfo,omitempty"`
	ParameterInfo        *ParameterInfo `protobuf:"bytes,14,opt,name=parameterInfo,proto3" json:"parameterInfo,omitempty"`
	XXX_NoUnkeyedLiteral struct{}       `json:"-"`
	XXX_unrecognized     []byte         `json:"-"`
	XXX_sizecache        int32          `json:"-"`
}

type SignInRsp struct {
	ParameterInfo        *ParameterInfo `protobuf:"bytes,1,opt,name=parameterInfo,proto3" json:"parameterInfo,omitempty"`
	UpgradeInfo          *UpgradeInfo   `protobuf:"bytes,2,opt,name=upgradeInfo,proto3" json:"upgradeInfo,omitempty"`
	XXX_NoUnkeyedLiteral struct{}       `json:"-"`
	XXX_unrecognized     []byte         `json:"-"`
	XXX_sizecache        int32          `json:"-"`
}

type SignOutReq struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

type SignOutRsp struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

type SignUpReq struct {
	Alg                  uint32   `protobuf:"varint,1,opt,name=alg,proto3" json:"alg,omitempty"`
	Hid                  string   `protobuf:"bytes,2,opt,name=hid,proto3" json:"hid,omitempty"`
	Key                  string   `protobuf:"bytes,3,opt,name=key,proto3" json:"key,omitempty"`
	Timestamp            uint64   `protobuf:"fixed64,4,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

type SignUpRsp struct {
	Alg                  uint32   `protobuf:"varint,1,opt,name=alg,proto3" json:"alg,omitempty"`
	Id                   string   `protobuf:"bytes,2,opt,name=id,proto3" json:"id,omitempty"`
	Key                  string   `protobuf:"bytes,3,opt,name=key,proto3" json:"key,omitempty"`
	Expire               uint64   `protobuf:"fixed64,4,opt,name=expire,proto3" json:"expire,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

type State struct {
	//latest term server has seen (initialized to 0
	//on first boot, increases monotonically)
	CurrentTerm uint64 `json:"currentTerm"`

	//candidateId that received vote in current
	//term (or null if none)
	VotedFor string `json:"votedFor"`

	//log entries; each entry contains command
	//for state machine, and term when entry
	//was received by leader (first index is 1)
	Log []interface{} `json:"log"`

	//index of highest log entry known to be
	//committed (initialized to 0, increases monotonically)
	CommitIndex uint64 `json:"commitIndex"`

	//index of highest log entry applied to state
	//machine (initialized to 0, increases monotonically)
	LastApplied uint64 `json:"lastApplied"`

	//for each server, index of the next log entry
	//to send to that server (initialized to leader last log index + 1)
	NextIndex []uint64 `json:"nextIndex"`

	//for each server, index of highest log entry
	//	known to be replicated on server
	//(initialized to 0, increases monotonically)
	MatchIndex []uint64 `json:"matchIndex"`
}

type StreamMessage struct {
	Proc                 Procedure `protobuf:"varint,1,opt,name=proc,proto3,enum=node.Procedure" json:"proc,omitempty"`
	Code                 ErrorCode `protobuf:"varint,2,opt,name=code,proto3,enum=node.ErrorCode" json:"code,omitempty"`
	XXX_NoUnkeyedLiteral struct{}  `json:"-"`
	XXX_unrecognized     []byte    `json:"-"`
	XXX_sizecache        int32     `json:"-"`
}

type UnimplementedS1ServiceServer struct {
}

type UpgradeInfo struct {
	// module name - url/endpoint
	Endpoints            map[string]string `` /* 159-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

type UpgradeNotice struct {
	ParameterInfo        *ParameterInfo `protobuf:"bytes,1,opt,name=parameterInfo,proto3" json:"parameterInfo,omitempty"`
	UpgradeInfo          *UpgradeInfo   `protobuf:"bytes,2,opt,name=upgradeInfo,proto3" json:"upgradeInfo,omitempty"`
	XXX_NoUnkeyedLiteral struct{}       `json:"-"`
	XXX_unrecognized     []byte         `json:"-"`
	XXX_sizecache        int32          `json:"-"`
}

type Utilization struct {
	CpuRate              uint32   `protobuf:"varint,1,opt,name=cpuRate,proto3" json:"cpuRate,omitempty"`
	MemRate              uint32   `protobuf:"varint,2,opt,name=memRate,proto3" json:"memRate,omitempty"`
	StorageRate          uint32   `protobuf:"varint,3,opt,name=storageRate,proto3" json:"storageRate,omitempty"`
	DiskReadRate         float32  `protobuf:"fixed32,4,opt,name=diskReadRate,proto3" json:"diskReadRate,omitempty"`
	DiskWrtnRate         float32  `protobuf:"fixed32,5,opt,name=diskWrtnRate,proto3" json:"diskWrtnRate,omitempty"`
	NetReadRate          float32  `protobuf:"fixed32,6,opt,name=netReadRate,proto3" json:"netReadRate,omitempty"`
	NetWrtnRate          float32  `protobuf:"fixed32,7,opt,name=netWrtnRate,proto3" json:"netWrtnRate,omitempty"`
	NetworkDelay         uint32   `protobuf:"varint,8,opt,name=networkDelay,proto3" json:"networkDelay,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

type VersionInfo struct {
	// module name - version
	Versions             map[string]string `` /* 157-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

type VoteReq struct {
	Term         uint64 `json:"term"`         //candidate’s term
	CandidateID  string `json:"candidateId"`  //candidate id requesting vote
	LastLogIndex uint64 `json:"lastLogIndex"` //index of candidate’s last log entry (§5.4)
	LastLogTerm  uint64 `json:"lastLogTerm"`  //term of candidate’s last log entry (§5.4)
}

type VoteRsp struct {
	Term        uint64 `json:"term"`        //currentTerm, for candidate to update itself
	VoteGranted bool   `json:"voteGranted"` //true means candidate received vote
}