communication

Documentation

Index

• type BlockMessage
• type HeartbeatMessage
• type HeartbeatResponse
• type RPCClient
  • func NewRPClient(dsn string, timeout time.Duration) (*RPCClient, error)
• type RegistrationMessage
• type SyncDoneResponse

Types

type BlockMessage

type BlockMessage struct {
	Data     []byte
	Checksum string
}

type HeartbeatMessage

type HeartbeatMessage struct {
	NodeID      NodeID
	Addr        string
	Blocks      []BlockID
	Utilization int64
	Timestamp   time.Time
}

HeartbeatMessage is the heartbeat packet send to master, which includes node's metric. TODO add metric

type HeartbeatResponse

type HeartbeatResponse struct {
	DeadBlocks []BlockID
	SyncBlocks []*SyncBlock
}

HeartbeatResponse send from master to chunk node to do some action to keep consistency of cluster.

type RPCClient

type RPCClient struct {
	Connection *rpc.Client
}

func NewRPClient

func NewRPClient(dsn string, timeout time.Duration) (*RPCClient, error)

type RegistrationMessage

type RegistrationMessage struct {
	Addr string
}

RegistrationMessage is the first message send to master which includes chunk node's address information.

type SyncDoneResponse

type SyncDoneResponse struct {
}