Documentation ¶
Index ¶
- type ApplicationInfo
- type CargoInfo
- func (cargoInfo *CargoInfo) CleanUp()
- func (cargoInfo *CargoInfo) ListenTasks(wg *sync.WaitGroup)
- func (cargoInfo *CargoInfo) ReadFromFile(appID string, fileName string) string
- func (cargoInfo *CargoInfo) Register()
- func (cargoInfo *CargoInfo) SendToReplicas()
- func (cargoInfo *CargoInfo) StrongWriteToReplicas(replicaData cargoToCargo.ReplicaData)
- func (cargoInfo *CargoInfo) WriteToFile(appID string, fileName string, content string, writeSize int, isReplica bool)
- func (cargoInfo *CargoInfo) WriteToReplicas()
- type CargoMgrComm
- type CargoReplicaComm
- type CargoToCargoComm
- type ReplicaData
- type TaskToCargoComm
- func (ttc *TaskToCargoComm) LoadFromCargo(ctx context.Context, fileInfo *taskToCargo.FileInfo) (*taskToCargo.DataToLoad, error)
- func (ttc *TaskToCargoComm) ReadFromCargo(ctx context.Context, readInfo *taskToCargo.ReadInfo) (*taskToCargo.ReadData, error)
- func (ttc *TaskToCargoComm) StoreInCargo(ctx context.Context, dts *taskToCargo.DataToStore) (*taskToCargo.Ack, error)
- func (ttc *TaskToCargoComm) WriteToCargo(ctx context.Context, wtc *taskToCargo.WriteData) (*taskToCargo.Ack, error)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type ApplicationInfo ¶
type ApplicationInfo struct { AppID string // contains filtered or unexported fields }
type CargoInfo ¶
type CargoInfo struct { ID string PublicIP string Port int64 CargoMgrIP string CargoMgrPort string Lat float64 Lon float64 TSize float64 RSize float64 AppInfo map[string]*ApplicationInfo ReplicaChannel chan cargoToCargo.ReplicaData ReplicaChan chan ReplicaData CRC map[string]CargoReplicaComm CMC CargoMgrComm TTC TaskToCargoComm CTC CargoToCargoComm // contains filtered or unexported fields }
func Init ¶
////////////////////////////////////////////////////////////////////////////////////////////////////// //////////////////////////////////////////////////////////////////////////////////////////////////////
func (*CargoInfo) ListenTasks ¶
func (*CargoInfo) ReadFromFile ¶
func (*CargoInfo) SendToReplicas ¶
func (cargoInfo *CargoInfo) SendToReplicas()
func (*CargoInfo) StrongWriteToReplicas ¶
func (cargoInfo *CargoInfo) StrongWriteToReplicas(replicaData cargoToCargo.ReplicaData)
func (*CargoInfo) WriteToFile ¶
func (*CargoInfo) WriteToReplicas ¶
func (cargoInfo *CargoInfo) WriteToReplicas()
type CargoMgrComm ¶
type CargoMgrComm struct {
// contains filtered or unexported fields
}
type CargoReplicaComm ¶
type CargoReplicaComm struct {
// contains filtered or unexported fields
}
type CargoToCargoComm ¶
type CargoToCargoComm struct { cargoToCargo.UnimplementedRpcCargoToCargoServer // contains filtered or unexported fields }
func (*CargoToCargoComm) StoreInReplica ¶
func (ctc *CargoToCargoComm) StoreInReplica(ctx context.Context, rd *cargoToCargo.ReplicaData) (*cargoToCargo.Ack, error)
func (*CargoToCargoComm) WriteInReplica ¶
func (ctc *CargoToCargoComm) WriteInReplica(ctx context.Context, rd *cargoToCargo.ReplicaData) (*cargoToCargo.Ack, error)
type ReplicaData ¶
type ReplicaData struct {
// contains filtered or unexported fields
}
type TaskToCargoComm ¶
type TaskToCargoComm struct { taskToCargo.UnimplementedRpcTaskToCargoServer // contains filtered or unexported fields }
func (*TaskToCargoComm) LoadFromCargo ¶
func (ttc *TaskToCargoComm) LoadFromCargo(ctx context.Context, fileInfo *taskToCargo.FileInfo) (*taskToCargo.DataToLoad, error)
func (*TaskToCargoComm) ReadFromCargo ¶
func (ttc *TaskToCargoComm) ReadFromCargo(ctx context.Context, readInfo *taskToCargo.ReadInfo) (*taskToCargo.ReadData, error)
func (*TaskToCargoComm) StoreInCargo ¶
func (ttc *TaskToCargoComm) StoreInCargo(ctx context.Context, dts *taskToCargo.DataToStore) (*taskToCargo.Ack, error)
func (*TaskToCargoComm) WriteToCargo ¶
func (ttc *TaskToCargoComm) WriteToCargo(ctx context.Context, wtc *taskToCargo.WriteData) (*taskToCargo.Ack, error)
Click to show internal directories.
Click to hide internal directories.