lib

Documentation

Index

• type ApplicationInfo
• type CargoComm
  • func (cc *CargoComm) AcquireWriteLock(ctx context.Context, appInfo *cargoToMgr.AppInfo) (*cargoToMgr.LockAck, error)
  • func (cc *CargoComm) GetReplicaInfo(ctx context.Context, appInfo *cargoToMgr.AppInfo) (*cargoToMgr.ReplicaInfo, error)
  • func (cc *CargoComm) RegisterToMgr(ctx context.Context, cargoInfo *cargoToMgr.CargoInfo) (*cargoToMgr.Ack, error)
  • func (cc *CargoComm) ReleaseWriteLock(ctx context.Context, appInfo *cargoToMgr.AppInfo) (*cargoToMgr.ReleaseAck, error)
• type CargoMgrInfo
  • func Init(port string) *CargoMgrInfo
  • func (cargoMgrInfo *CargoMgrInfo) ListenRoutine(wg *sync.WaitGroup)
• type CargoNode
• type TaskComm
  • func (tcm *TaskComm) RequestCargo(ctx context.Context, requesterInfo *taskToCargoMgr.RequesterInfo) (*taskToCargoMgr.Cargos, error)

Types

type ApplicationInfo

type ApplicationInfo struct {
	AppID string

	IPs       []string
	Ports     []string
	CType     string
	Mutex     *sync.Mutex
	Cond      *sync.Cond
	WriteLock bool
	// contains filtered or unexported fields
}

type CargoComm

type CargoComm struct {
	cargoToMgr.UnimplementedRpcCargoToMgrServer
	// contains filtered or unexported fields
}

func (*CargoComm) AcquireWriteLock

func (cc *CargoComm) AcquireWriteLock(ctx context.Context, appInfo *cargoToMgr.AppInfo) (*cargoToMgr.LockAck, error)

func (*CargoComm) GetReplicaInfo

func (cc *CargoComm) GetReplicaInfo(ctx context.Context, appInfo *cargoToMgr.AppInfo) (*cargoToMgr.ReplicaInfo, error)

func (*CargoComm) RegisterToMgr

func (cc *CargoComm) RegisterToMgr(ctx context.Context, cargoInfo *cargoToMgr.CargoInfo) (*cargoToMgr.Ack, error)

func (*CargoComm) ReleaseWriteLock

func (cc *CargoComm) ReleaseWriteLock(ctx context.Context, appInfo *cargoToMgr.AppInfo) (*cargoToMgr.ReleaseAck, error)

type CargoMgrInfo

type CargoMgrInfo struct {
	Port    string
	CC      CargoComm
	TCM     TaskComm
	Cargos  map[string]CargoNode
	AppInfo map[string]*ApplicationInfo
}

func Init

func Init(port string) *CargoMgrInfo

func (*CargoMgrInfo) ListenRoutine

func (cargoMgrInfo *CargoMgrInfo) ListenRoutine(wg *sync.WaitGroup)

type CargoNode

type CargoNode struct {
	IP    string
	Port  string
	ID    string // <geohash + uuid>
	Lat   float64
	Lon   float64
	TSize float64
	RSize float64
}

type TaskComm

type TaskComm struct {
	taskToCargoMgr.UnimplementedRpcTaskToCargoMgrServer
	// contains filtered or unexported fields
}

func (*TaskComm) RequestCargo

func (tcm *TaskComm) RequestCargo(ctx context.Context, requesterInfo *taskToCargoMgr.RequesterInfo) (*taskToCargoMgr.Cargos, error)