fs533lib

type Configuration struct {
	InstanceID                              string //instanceId of EC2 instance (a node)
	IPAddress                               string //instance's private address
	TCPPort                                 int    //TCP port which is used for listening to leave/join requests
	UDPPort                                 int    //UDP port which is used for listening to heartbeat messages
	LogPath                                 string //log files directory
	Fs533FilePath                           string //fs533 files directory
	LocalFilePath                           string //local files directory
	HostAddress                             string //host address which is IPAddress:TCPPort
	HeartbeatAddress                        string //heartbeat address which is IPAddress:UDPPort
	MaxDatagramSize                         int
	Timeout                                 int      //timeout for Join/Leave request
	HeartbeatIntervalTimeInMilliseconds     int      //interval time between 2 heartbeat messages
	HeartbeatTimeoutInMilliseconds          int      //timeout indicating that the node has failed
	GatewayNodes                            []string //3 leading nodes which are supposed that they will not fail at the same
	NumberOfPrecessorsAndSuccessors         int      //number of the predecessors and successors on the healthcheck topology ring
	NumberOfReplicas                        int      //number of preference nodes where storing replicate of a file
	WriteQuorum                             int      //write quorum
	ReadQuorum                              int      //read quorum
	FileChunkSize                           int      //chunk size for treaming file
	PendingWriteTransactionTimeoutInSeconds int      //a pending write transaction will be timeout if it reaches this total time
	NumberOfHeartbeatsShown                 int      //number of heartbeats which are printed out
	HearbeatLog                             bool     //turn on/off heartbeat log
	Membershiplog                           bool     //turn on/off membership log
}

type FetchedFileMetadata struct {
	Fs533FileName    string //file name on the fs533 file system
	Fs533FileVersion int32  //file version
	Fs533FileSize    int32  //file size
	LocalFileName    string //file name which is fetched on local storag
}

type FileClient struct{}

type FileOperation struct{}

type FileServer struct{}

type Fs533FileMetadata struct {
	Fs533FileName    string    //file name on the fs533 file system
	Fs533FileVersion int32     //file version
	Fs533FileSize    int32     //file size
	RegisteredTime   time.Time //latest registered time
	PreferenceNodes  []string  //list of its replica nodes
}

type LogManager struct{}

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

type MonitorPacket struct {
	NodeAddress      string
	LastTimeReceived time.Time
	Count            int32
}

type TemporaryFs533File struct {
	Fs533FileName     string //the file being written
	Fs533FileVersion  int32  //the new version of this file
	RequestID         string //id of the write request which is to differentiate write transaction
	TemporaryFileName string //the file will be saved as a temporary file while it is waiting for the commit request
	Fs533FileSize     int32  //file size
}

type WriteTransaction struct {
	Fs533FileName    string   //the file being written
	Fs533FileVersion int32    //the new version of this file
	RequestID        string   //id of the write request which is to differentiate write transaction
	PreferenceNodes  []string //list of its replica nodes
	RegisteredTime   time.Time
}