Documentation
¶
Index ¶
- Variables
- type ChainStatus
- func (*ChainStatus) Descriptor() ([]byte, []int)deprecated
- func (x *ChainStatus) GetLeaderRank() []uint32
- func (x *ChainStatus) GetNodeStatus() []*NodeStatus
- func (*ChainStatus) ProtoMessage()
- func (x *ChainStatus) ProtoReflect() protoreflect.Message
- func (x *ChainStatus) Reset()
- func (x *ChainStatus) String() string
- type Deliverable
- func (*Deliverable) Descriptor() ([]byte, []int)deprecated
- func (x *Deliverable) GetError() string
- func (x *Deliverable) GetNodeId() uint32
- func (x *Deliverable) GetOrderId() uint64
- func (x *Deliverable) GetOutput() []byte
- func (*Deliverable) ProtoMessage()
- func (x *Deliverable) ProtoReflect() protoreflect.Message
- func (x *Deliverable) Reset()
- func (x *Deliverable) String() string
- type NodeStatus
- func (*NodeStatus) Descriptor() ([]byte, []int)deprecated
- func (x *NodeStatus) GetCpuCore() uint32
- func (x *NodeStatus) GetCpuUsage() float64
- func (x *NodeStatus) GetFailCount() uint32
- func (x *NodeStatus) GetHost() string
- func (x *NodeStatus) GetLoading() int32
- func (x *NodeStatus) GetMemoryMB() uint32
- func (x *NodeStatus) GetNodeId() uint32
- func (x *NodeStatus) GetOffline() bool
- func (x *NodeStatus) GetProcessedInMinute() uint32
- func (x *NodeStatus) GetRepPort() uint32
- func (x *NodeStatus) GetSendTime() int64
- func (x *NodeStatus) GetServeMenuIds() []uint32
- func (*NodeStatus) ProtoMessage()
- func (x *NodeStatus) ProtoReflect() protoreflect.Message
- func (x *NodeStatus) Reset()
- func (x *NodeStatus) String() string
- type Order
- func (*Order) Descriptor() ([]byte, []int)deprecated
- func (x *Order) GetDeadline() int64
- func (x *Order) GetDishId() uint32
- func (x *Order) GetId() uint64
- func (x *Order) GetInput() []byte
- func (x *Order) GetMenuId() uint32
- func (x *Order) GetNodeId() uint32
- func (*Order) ProtoMessage()
- func (x *Order) ProtoReflect() protoreflect.Message
- func (x *Order) Reset()
- func (x *Order) String() string
Constants ¶
This section is empty.
Variables ¶
View Source
var File_proto_proto protoreflect.FileDescriptor
Functions ¶
This section is empty.
Types ¶
type ChainStatus ¶
type ChainStatus struct {
NodeStatus []*NodeStatus `protobuf:"bytes,1,rep,name=nodeStatus,proto3" json:"nodeStatus,omitempty"`
LeaderRank []uint32 `protobuf:"varint,2,rep,packed,name=leaderRank,proto3" json:"leaderRank,omitempty"`
// contains filtered or unexported fields
}
func (*ChainStatus) Descriptor
deprecated
func (*ChainStatus) Descriptor() ([]byte, []int)
Deprecated: Use ChainStatus.ProtoReflect.Descriptor instead.
func (*ChainStatus) GetLeaderRank ¶
func (x *ChainStatus) GetLeaderRank() []uint32
func (*ChainStatus) GetNodeStatus ¶
func (x *ChainStatus) GetNodeStatus() []*NodeStatus
func (*ChainStatus) ProtoMessage ¶
func (*ChainStatus) ProtoMessage()
func (*ChainStatus) ProtoReflect ¶
func (x *ChainStatus) ProtoReflect() protoreflect.Message
func (*ChainStatus) Reset ¶
func (x *ChainStatus) Reset()
func (*ChainStatus) String ¶
func (x *ChainStatus) String() string
type Deliverable ¶
type Deliverable struct {
Output []byte `protobuf:"bytes,1,opt,name=output,proto3" json:"output,omitempty"`
Error string `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty"`
OrderId uint64 `protobuf:"varint,3,opt,name=orderId,proto3" json:"orderId,omitempty"`
NodeId uint32 `protobuf:"varint,4,opt,name=nodeId,proto3" json:"nodeId,omitempty"`
// contains filtered or unexported fields
}
func (*Deliverable) Descriptor
deprecated
func (*Deliverable) Descriptor() ([]byte, []int)
Deprecated: Use Deliverable.ProtoReflect.Descriptor instead.
func (*Deliverable) GetError ¶
func (x *Deliverable) GetError() string
func (*Deliverable) GetNodeId ¶
func (x *Deliverable) GetNodeId() uint32
func (*Deliverable) GetOrderId ¶
func (x *Deliverable) GetOrderId() uint64
func (*Deliverable) GetOutput ¶
func (x *Deliverable) GetOutput() []byte
func (*Deliverable) ProtoMessage ¶
func (*Deliverable) ProtoMessage()
func (*Deliverable) ProtoReflect ¶
func (x *Deliverable) ProtoReflect() protoreflect.Message
func (*Deliverable) Reset ¶
func (x *Deliverable) Reset()
func (*Deliverable) String ¶
func (x *Deliverable) String() string
type NodeStatus ¶
type NodeStatus struct {
Host string `protobuf:"bytes,1,opt,name=host,proto3" json:"host,omitempty"`
ServeMenuIds []uint32 `protobuf:"varint,2,rep,packed,name=serveMenuIds,proto3" json:"serveMenuIds,omitempty"`
SendTime int64 `protobuf:"varint,3,opt,name=sendTime,proto3" json:"sendTime,omitempty"`
CpuUsage float64 `protobuf:"fixed64,4,opt,name=cpuUsage,proto3" json:"cpuUsage,omitempty"`
ProcessedInMinute uint32 `protobuf:"varint,5,opt,name=processedInMinute,proto3" json:"processedInMinute,omitempty"`
NodeId uint32 `protobuf:"varint,6,opt,name=nodeId,proto3" json:"nodeId,omitempty"`
Loading int32 `protobuf:"varint,7,opt,name=loading,proto3" json:"loading,omitempty"`
MemoryMB uint32 `protobuf:"varint,8,opt,name=memoryMB,proto3" json:"memoryMB,omitempty"`
CpuCore uint32 `protobuf:"varint,9,opt,name=cpuCore,proto3" json:"cpuCore,omitempty"`
RepPort uint32 `protobuf:"varint,10,opt,name=repPort,proto3" json:"repPort,omitempty"`
FailCount uint32 `protobuf:"varint,11,opt,name=failCount,proto3" json:"failCount,omitempty"`
Offline bool `protobuf:"varint,12,opt,name=offline,proto3" json:"offline,omitempty"`
// contains filtered or unexported fields
}
func (*NodeStatus) Descriptor
deprecated
func (*NodeStatus) Descriptor() ([]byte, []int)
Deprecated: Use NodeStatus.ProtoReflect.Descriptor instead.
func (*NodeStatus) GetCpuCore ¶
func (x *NodeStatus) GetCpuCore() uint32
func (*NodeStatus) GetCpuUsage ¶
func (x *NodeStatus) GetCpuUsage() float64
func (*NodeStatus) GetFailCount ¶
func (x *NodeStatus) GetFailCount() uint32
func (*NodeStatus) GetHost ¶
func (x *NodeStatus) GetHost() string
func (*NodeStatus) GetLoading ¶
func (x *NodeStatus) GetLoading() int32
func (*NodeStatus) GetMemoryMB ¶
func (x *NodeStatus) GetMemoryMB() uint32
func (*NodeStatus) GetNodeId ¶
func (x *NodeStatus) GetNodeId() uint32
func (*NodeStatus) GetOffline ¶
func (x *NodeStatus) GetOffline() bool
func (*NodeStatus) GetProcessedInMinute ¶
func (x *NodeStatus) GetProcessedInMinute() uint32
func (*NodeStatus) GetRepPort ¶
func (x *NodeStatus) GetRepPort() uint32
func (*NodeStatus) GetSendTime ¶
func (x *NodeStatus) GetSendTime() int64
func (*NodeStatus) GetServeMenuIds ¶
func (x *NodeStatus) GetServeMenuIds() []uint32
func (*NodeStatus) ProtoMessage ¶
func (*NodeStatus) ProtoMessage()
func (*NodeStatus) ProtoReflect ¶
func (x *NodeStatus) ProtoReflect() protoreflect.Message
func (*NodeStatus) Reset ¶
func (x *NodeStatus) Reset()
func (*NodeStatus) String ¶
func (x *NodeStatus) String() string
type Order ¶
type Order struct {
Input []byte `protobuf:"bytes,1,opt,name=input,proto3" json:"input,omitempty"`
Deadline int64 `protobuf:"varint,2,opt,name=deadline,proto3" json:"deadline,omitempty"`
Id uint64 `protobuf:"varint,3,opt,name=id,proto3" json:"id,omitempty"`
NodeId uint32 `protobuf:"varint,4,opt,name=nodeId,proto3" json:"nodeId,omitempty"`
MenuId uint32 `protobuf:"varint,5,opt,name=menuId,proto3" json:"menuId,omitempty"`
DishId uint32 `protobuf:"varint,6,opt,name=dishId,proto3" json:"dishId,omitempty"`
// contains filtered or unexported fields
}
func (*Order) Descriptor
deprecated
func (*Order) GetDeadline ¶
func (*Order) ProtoMessage ¶
func (*Order) ProtoMessage()
func (*Order) ProtoReflect ¶
func (x *Order) ProtoReflect() protoreflect.Message
Click to show internal directories.
Click to hide internal directories.