taskToCargoMgr

Documentation

Index

• Variables
• func RegisterRpcTaskToCargoMgrServer(s *grpc.Server, srv RpcTaskToCargoMgrServer)
• type Cargos
  • func (*Cargos) Descriptor() ([]byte, []int)
  • func (x *Cargos) GetIPs() []string
  • func (x *Cargos) GetPorts() []string
  • func (*Cargos) ProtoMessage()
  • func (x *Cargos) ProtoReflect() protoreflect.Message
  • func (x *Cargos) Reset()
  • func (x *Cargos) String() string
• type RequesterInfo
  • func (*RequesterInfo) Descriptor() ([]byte, []int)
  • func (x *RequesterInfo) GetAppID() string
  • func (x *RequesterInfo) GetCType() string
  • func (x *RequesterInfo) GetLat() float64
  • func (x *RequesterInfo) GetLon() float64
  • func (x *RequesterInfo) GetNReplicas() int64
  • func (x *RequesterInfo) GetSize() int64
  • func (*RequesterInfo) ProtoMessage()
  • func (x *RequesterInfo) ProtoReflect() protoreflect.Message
  • func (x *RequesterInfo) Reset()
  • func (x *RequesterInfo) String() string
• type RpcTaskToCargoMgrClient
  • func NewRpcTaskToCargoMgrClient(cc grpc.ClientConnInterface) RpcTaskToCargoMgrClient
• type RpcTaskToCargoMgrServer
• type UnimplementedRpcTaskToCargoMgrServer
  • func (*UnimplementedRpcTaskToCargoMgrServer) RequestCargo(context.Context, *RequesterInfo) (*Cargos, error)

Variables

var File_taskToCargoMgr_proto protoreflect.FileDescriptor

Functions

func RegisterRpcTaskToCargoMgrServer

func RegisterRpcTaskToCargoMgrServer(s *grpc.Server, srv RpcTaskToCargoMgrServer)

Types

type Cargos

type Cargos struct {
	IPs   []string `protobuf:"bytes,1,rep,name=IPs,proto3" json:"IPs,omitempty"`
	Ports []string `protobuf:"bytes,2,rep,name=Ports,proto3" json:"Ports,omitempty"`
	// contains filtered or unexported fields
}

func (*Cargos) Descriptor

func (*Cargos) Descriptor() ([]byte, []int)

Deprecated: Use Cargos.ProtoReflect.Descriptor instead.

func (*Cargos) GetIPs

func (x *Cargos) GetIPs() []string

func (*Cargos) GetPorts

func (x *Cargos) GetPorts() []string

func (*Cargos) ProtoMessage

func (*Cargos) ProtoMessage()

func (*Cargos) ProtoReflect

func (x *Cargos) ProtoReflect() protoreflect.Message

func (*Cargos) Reset

func (x *Cargos) Reset()

func (*Cargos) String

func (x *Cargos) String() string

type RequesterInfo

type RequesterInfo struct {
	Lat       float64 `protobuf:"fixed64,1,opt,name=lat,proto3" json:"lat,omitempty"`
	Lon       float64 `protobuf:"fixed64,2,opt,name=lon,proto3" json:"lon,omitempty"`
	Size      int64   `protobuf:"varint,3,opt,name=size,proto3" json:"size,omitempty"`
	NReplicas int64   `protobuf:"varint,4,opt,name=nReplicas,proto3" json:"nReplicas,omitempty"`
	AppID     string  `protobuf:"bytes,5,opt,name=appID,proto3" json:"appID,omitempty"`
	CType     string  `protobuf:"bytes,6,opt,name=cType,proto3" json:"cType,omitempty"`
	// contains filtered or unexported fields
}

func (*RequesterInfo) Descriptor

func (*RequesterInfo) Descriptor() ([]byte, []int)

Deprecated: Use RequesterInfo.ProtoReflect.Descriptor instead.

func (*RequesterInfo) GetAppID

func (x *RequesterInfo) GetAppID() string

func (*RequesterInfo) GetCType

func (x *RequesterInfo) GetCType() string

func (*RequesterInfo) GetLat

func (x *RequesterInfo) GetLat() float64

func (*RequesterInfo) GetLon

func (x *RequesterInfo) GetLon() float64

func (*RequesterInfo) GetNReplicas

func (x *RequesterInfo) GetNReplicas() int64

func (*RequesterInfo) GetSize

func (x *RequesterInfo) GetSize() int64

func (*RequesterInfo) ProtoMessage

func (*RequesterInfo) ProtoMessage()

func (*RequesterInfo) ProtoReflect

func (x *RequesterInfo) ProtoReflect() protoreflect.Message

func (*RequesterInfo) Reset

func (x *RequesterInfo) Reset()

func (*RequesterInfo) String

func (x *RequesterInfo) String() string

type RpcTaskToCargoMgrClient

type RpcTaskToCargoMgrClient interface {
	RequestCargo(ctx context.Context, in *RequesterInfo, opts ...grpc.CallOption) (*Cargos, error)
}

RpcTaskToCargoMgrClient is the client API for RpcTaskToCargoMgr service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewRpcTaskToCargoMgrClient

func NewRpcTaskToCargoMgrClient(cc grpc.ClientConnInterface) RpcTaskToCargoMgrClient

type RpcTaskToCargoMgrServer

type RpcTaskToCargoMgrServer interface {
	RequestCargo(context.Context, *RequesterInfo) (*Cargos, error)
}

RpcTaskToCargoMgrServer is the server API for RpcTaskToCargoMgr service.

type UnimplementedRpcTaskToCargoMgrServer

type UnimplementedRpcTaskToCargoMgrServer struct {
}

UnimplementedRpcTaskToCargoMgrServer can be embedded to have forward compatible implementations.

func (*UnimplementedRpcTaskToCargoMgrServer) RequestCargo

func (*UnimplementedRpcTaskToCargoMgrServer) RequestCargo(context.Context, *RequesterInfo) (*Cargos, error)