cargoToMgr

package

v0.0.0-...-31d405b Latest Latest Go to latest Published: May 19, 2021 License: MIT Imports: 9 Imported by: 1

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/ArmadaStore/comms

Links

Open Source Insights

Documentation ¶

Index ¶

Variables
func RegisterRpcCargoToMgrServer(s *grpc.Server, srv RpcCargoToMgrServer)
type Ack
type AppInfo
type CargoInfo
type LockAck
type ReleaseAck
type ReplicaInfo
type RpcCargoToMgrClient
- func NewRpcCargoToMgrClient(cc grpc.ClientConnInterface) RpcCargoToMgrClient
type RpcCargoToMgrServer
type UnimplementedRpcCargoToMgrServer

Constants ¶

This section is empty.

Variables ¶

View Source

var File_cargoToMgr_proto protoreflect.FileDescriptor

Functions ¶

func RegisterRpcCargoToMgrServer ¶

func RegisterRpcCargoToMgrServer(s *grpc.Server, srv RpcCargoToMgrServer)

Types ¶

type Ack ¶

type Ack struct {
	ID  string `protobuf:"bytes,1,opt,name=ID,proto3" json:"ID,omitempty"`
	Ack string `protobuf:"bytes,2,opt,name=ack,proto3" json:"ack,omitempty"`
	// contains filtered or unexported fields
}

func (*Ack) Descriptor deprecated

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

Deprecated: Use Ack.ProtoReflect.Descriptor instead.

func (*Ack) GetAck ¶

func (x *Ack) GetAck() string

func (*Ack) GetID ¶

func (x *Ack) GetID() string

func (*Ack) ProtoMessage ¶

func (*Ack) ProtoMessage()

func (*Ack) ProtoReflect ¶

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

func (*Ack) Reset ¶

func (x *Ack) Reset()

func (*Ack) String ¶

func (x *Ack) String() string

type AppInfo ¶

type AppInfo struct {
	AppID string `protobuf:"bytes,1,opt,name=AppID,proto3" json:"AppID,omitempty"`
	// contains filtered or unexported fields
}

func (*AppInfo) Descriptor deprecated

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

Deprecated: Use AppInfo.ProtoReflect.Descriptor instead.

func (*AppInfo) GetAppID ¶

func (x *AppInfo) GetAppID() string

func (*AppInfo) ProtoMessage ¶

func (*AppInfo) ProtoMessage()

func (*AppInfo) ProtoReflect ¶

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

func (*AppInfo) Reset ¶

func (x *AppInfo) Reset()

func (*AppInfo) String ¶

func (x *AppInfo) String() string

type CargoInfo ¶

type CargoInfo struct {
	IP    string  `protobuf:"bytes,1,opt,name=IP,proto3" json:"IP,omitempty"`
	Port  string  `protobuf:"bytes,2,opt,name=Port,proto3" json:"Port,omitempty"`
	TSize float64 `protobuf:"fixed64,3,opt,name=TSize,proto3" json:"TSize,omitempty"`
	Lat   float64 `protobuf:"fixed64,4,opt,name=Lat,proto3" json:"Lat,omitempty"`
	Lon   float64 `protobuf:"fixed64,5,opt,name=Lon,proto3" json:"Lon,omitempty"`
	// contains filtered or unexported fields
}

func (*CargoInfo) Descriptor deprecated

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

Deprecated: Use CargoInfo.ProtoReflect.Descriptor instead.

func (*CargoInfo) GetIP ¶

func (x *CargoInfo) GetIP() string

func (*CargoInfo) GetLat ¶

func (x *CargoInfo) GetLat() float64

func (*CargoInfo) GetLon ¶

func (x *CargoInfo) GetLon() float64

func (*CargoInfo) GetPort ¶

func (x *CargoInfo) GetPort() string

func (*CargoInfo) GetTSize ¶

func (x *CargoInfo) GetTSize() float64

func (*CargoInfo) ProtoMessage ¶

func (*CargoInfo) ProtoMessage()

func (*CargoInfo) ProtoReflect ¶

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

func (*CargoInfo) Reset ¶

func (x *CargoInfo) Reset()

func (*CargoInfo) String ¶

func (x *CargoInfo) String() string

type LockAck ¶

type LockAck struct {
	Locked bool `protobuf:"varint,1,opt,name=locked,proto3" json:"locked,omitempty"`
	// contains filtered or unexported fields
}

func (*LockAck) Descriptor deprecated

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

Deprecated: Use LockAck.ProtoReflect.Descriptor instead.

func (*LockAck) GetLocked ¶

func (x *LockAck) GetLocked() bool

func (*LockAck) ProtoMessage ¶

func (*LockAck) ProtoMessage()

func (*LockAck) ProtoReflect ¶

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

func (*LockAck) Reset ¶

func (x *LockAck) Reset()

func (*LockAck) String ¶

func (x *LockAck) String() string

type ReleaseAck ¶

type ReleaseAck struct {
	Released bool `protobuf:"varint,1,opt,name=released,proto3" json:"released,omitempty"`
	// contains filtered or unexported fields
}

func (*ReleaseAck) Descriptor deprecated

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

Deprecated: Use ReleaseAck.ProtoReflect.Descriptor instead.

func (*ReleaseAck) GetReleased ¶

func (x *ReleaseAck) GetReleased() bool

func (*ReleaseAck) ProtoMessage ¶

func (*ReleaseAck) ProtoMessage()

func (*ReleaseAck) ProtoReflect ¶

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

func (*ReleaseAck) Reset ¶

func (x *ReleaseAck) Reset()

func (*ReleaseAck) String ¶

func (x *ReleaseAck) String() string

type ReplicaInfo ¶

type ReplicaInfo struct {
	CargoID []string `protobuf:"bytes,1,rep,name=cargoID,proto3" json:"cargoID,omitempty"`
	IP      []string `protobuf:"bytes,2,rep,name=IP,proto3" json:"IP,omitempty"`
	Port    []string `protobuf:"bytes,3,rep,name=Port,proto3" json:"Port,omitempty"`
	CType   string   `protobuf:"bytes,4,opt,name=cType,proto3" json:"cType,omitempty"`
	// contains filtered or unexported fields
}

func (*ReplicaInfo) Descriptor deprecated

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

Deprecated: Use ReplicaInfo.ProtoReflect.Descriptor instead.

func (*ReplicaInfo) GetCType ¶

func (x *ReplicaInfo) GetCType() string

func (*ReplicaInfo) GetCargoID ¶

func (x *ReplicaInfo) GetCargoID() []string

func (*ReplicaInfo) GetIP ¶

func (x *ReplicaInfo) GetIP() []string

func (*ReplicaInfo) GetPort ¶

func (x *ReplicaInfo) GetPort() []string

func (*ReplicaInfo) ProtoMessage ¶

func (*ReplicaInfo) ProtoMessage()

func (*ReplicaInfo) ProtoReflect ¶

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

func (*ReplicaInfo) Reset ¶

func (x *ReplicaInfo) Reset()

func (*ReplicaInfo) String ¶

func (x *ReplicaInfo) String() string

type RpcCargoToMgrClient ¶

type RpcCargoToMgrClient interface {
	RegisterToMgr(ctx context.Context, in *CargoInfo, opts ...grpc.CallOption) (*Ack, error)
	GetReplicaInfo(ctx context.Context, in *AppInfo, opts ...grpc.CallOption) (*ReplicaInfo, error)
	AcquireWriteLock(ctx context.Context, in *AppInfo, opts ...grpc.CallOption) (*LockAck, error)
	ReleaseWriteLock(ctx context.Context, in *AppInfo, opts ...grpc.CallOption) (*ReleaseAck, error)
}

RpcCargoToMgrClient is the client API for RpcCargoToMgr service.

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

func NewRpcCargoToMgrClient ¶

func NewRpcCargoToMgrClient(cc grpc.ClientConnInterface) RpcCargoToMgrClient

type RpcCargoToMgrServer ¶

type RpcCargoToMgrServer interface {
	RegisterToMgr(context.Context, *CargoInfo) (*Ack, error)
	GetReplicaInfo(context.Context, *AppInfo) (*ReplicaInfo, error)
	AcquireWriteLock(context.Context, *AppInfo) (*LockAck, error)
	ReleaseWriteLock(context.Context, *AppInfo) (*ReleaseAck, error)
}

RpcCargoToMgrServer is the server API for RpcCargoToMgr service.

type UnimplementedRpcCargoToMgrServer ¶

type UnimplementedRpcCargoToMgrServer struct {
}

UnimplementedRpcCargoToMgrServer can be embedded to have forward compatible implementations.

func (*UnimplementedRpcCargoToMgrServer) AcquireWriteLock ¶

func (*UnimplementedRpcCargoToMgrServer) AcquireWriteLock(context.Context, *AppInfo) (*LockAck, error)

func (*UnimplementedRpcCargoToMgrServer) GetReplicaInfo ¶

func (*UnimplementedRpcCargoToMgrServer) GetReplicaInfo(context.Context, *AppInfo) (*ReplicaInfo, error)

func (*UnimplementedRpcCargoToMgrServer) RegisterToMgr ¶

func (*UnimplementedRpcCargoToMgrServer) RegisterToMgr(context.Context, *CargoInfo) (*Ack, error)

func (*UnimplementedRpcCargoToMgrServer) ReleaseWriteLock ¶

func (*UnimplementedRpcCargoToMgrServer) ReleaseWriteLock(context.Context, *AppInfo) (*ReleaseAck, error)

Source Files ¶

View all Source files

cargoToMgr.pb.go

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