lib

package
v0.0.0-...-d02b376 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: May 19, 2021 License: MIT Imports: 18 Imported by: 0

Documentation

Index

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 Init(cargoMgrIP string, cargoMgrPort string, cargoPort string, volSize string) *CargoInfo

////////////////////////////////////////////////////////////////////////////////////////////////////// //////////////////////////////////////////////////////////////////////////////////////////////////////

func (*CargoInfo) CleanUp

func (cargoInfo *CargoInfo) CleanUp()

func (*CargoInfo) ListenTasks

func (cargoInfo *CargoInfo) ListenTasks(wg *sync.WaitGroup)

func (*CargoInfo) ReadFromFile

func (cargoInfo *CargoInfo) ReadFromFile(appID string, fileName string) string

func (*CargoInfo) Register

func (cargoInfo *CargoInfo) Register()

func (*CargoInfo) SendToReplicas

func (cargoInfo *CargoInfo) SendToReplicas()

func (*CargoInfo) StrongWriteToReplicas

func (cargoInfo *CargoInfo) StrongWriteToReplicas(replicaData cargoToCargo.ReplicaData)

func (*CargoInfo) WriteToFile

func (cargoInfo *CargoInfo) WriteToFile(appID string, fileName string, content string, writeSize int, isReplica bool)

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)

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL