deal

package
v1.0.3 Latest Latest
Warning

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

Go to latest
Published: Apr 22, 2022 License: GPL-3.0 Imports: 4 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

Functions

This section is empty.

Types

type MemberInfoNotice

type MemberInfoNotice struct {
	SessionCount uint64 `protobuf:"varint,1,opt,name=SessionCount,proto3" json:"SessionCount,omitempty"`
	// contains filtered or unexported fields
}

func (*MemberInfoNotice) Descriptor deprecated

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

Deprecated: Use MemberInfoNotice.ProtoReflect.Descriptor instead.

func (*MemberInfoNotice) GetSessionCount

func (x *MemberInfoNotice) GetSessionCount() uint64

func (*MemberInfoNotice) ProtoMessage

func (*MemberInfoNotice) ProtoMessage()

func (*MemberInfoNotice) ProtoReflect

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

func (*MemberInfoNotice) Reset

func (x *MemberInfoNotice) Reset()

func (*MemberInfoNotice) String

func (x *MemberInfoNotice) String() string

type MemberMchIDPush

type MemberMchIDPush struct {
	MchID uint64 `protobuf:"varint,1,opt,name=MchID,proto3" json:"MchID,omitempty"`
	// contains filtered or unexported fields
}

func (*MemberMchIDPush) Descriptor deprecated

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

Deprecated: Use MemberMchIDPush.ProtoReflect.Descriptor instead.

func (*MemberMchIDPush) GetMchID

func (x *MemberMchIDPush) GetMchID() uint64

func (*MemberMchIDPush) ProtoMessage

func (*MemberMchIDPush) ProtoMessage()

func (*MemberMchIDPush) ProtoReflect

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

func (*MemberMchIDPush) Reset

func (x *MemberMchIDPush) Reset()

func (*MemberMchIDPush) String

func (x *MemberMchIDPush) String() string

type MemberNode

type MemberNode struct {
	MchId        uint64  `protobuf:"varint,1,opt,name=MchId,proto3" json:"MchId,omitempty"`
	Version      string  `protobuf:"bytes,2,opt,name=Version,proto3" json:"Version,omitempty"`
	Addr         string  `protobuf:"bytes,3,opt,name=Addr,proto3" json:"Addr,omitempty"`
	LastTime     int64   `protobuf:"varint,4,opt,name=LastTime,proto3" json:"LastTime,omitempty"`
	SessionCount uint64  `protobuf:"varint,5,opt,name=SessionCount,proto3" json:"SessionCount,omitempty"`
	Psutil       *Psutil `protobuf:"bytes,6,opt,name=Psutil,proto3" json:"Psutil,omitempty"`
	InnerAddr    string  `protobuf:"bytes,7,opt,name=InnerAddr,proto3" json:"InnerAddr,omitempty"`
	// contains filtered or unexported fields
}

member node

func (*MemberNode) Descriptor deprecated

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

Deprecated: Use MemberNode.ProtoReflect.Descriptor instead.

func (*MemberNode) GetAddr

func (x *MemberNode) GetAddr() string

func (*MemberNode) GetInnerAddr

func (x *MemberNode) GetInnerAddr() string

func (*MemberNode) GetLastTime

func (x *MemberNode) GetLastTime() int64

func (*MemberNode) GetMchId

func (x *MemberNode) GetMchId() uint64

func (*MemberNode) GetPsutil

func (x *MemberNode) GetPsutil() *Psutil

func (*MemberNode) GetSessionCount

func (x *MemberNode) GetSessionCount() uint64

func (*MemberNode) GetVersion

func (x *MemberNode) GetVersion() string

func (*MemberNode) ProtoMessage

func (*MemberNode) ProtoMessage()

func (*MemberNode) ProtoReflect

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

func (*MemberNode) Reset

func (x *MemberNode) Reset()

func (*MemberNode) String

func (x *MemberNode) String() string

type MemberNodePush

type MemberNodePush struct {
	Node []*MemberNode `protobuf:"bytes,1,rep,name=Node,proto3" json:"Node,omitempty"`
	// contains filtered or unexported fields
}

func (*MemberNodePush) Descriptor deprecated

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

Deprecated: Use MemberNodePush.ProtoReflect.Descriptor instead.

func (*MemberNodePush) GetNode

func (x *MemberNodePush) GetNode() []*MemberNode

func (*MemberNodePush) ProtoMessage

func (*MemberNodePush) ProtoMessage()

func (*MemberNodePush) ProtoReflect

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

func (*MemberNodePush) Reset

func (x *MemberNodePush) Reset()

func (*MemberNodePush) String

func (x *MemberNodePush) String() string

type MemberNodeRequest

type MemberNodeRequest struct {
	// contains filtered or unexported fields
}

所有服务节点返回

func (*MemberNodeRequest) Descriptor deprecated

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

Deprecated: Use MemberNodeRequest.ProtoReflect.Descriptor instead.

func (*MemberNodeRequest) ProtoMessage

func (*MemberNodeRequest) ProtoMessage()

func (*MemberNodeRequest) ProtoReflect

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

func (*MemberNodeRequest) Reset

func (x *MemberNodeRequest) Reset()

func (*MemberNodeRequest) String

func (x *MemberNodeRequest) String() string

type MemberNodeResponse

type MemberNodeResponse struct {
	Node []*MemberNode `protobuf:"bytes,1,rep,name=Node,proto3" json:"Node,omitempty"`
	// contains filtered or unexported fields
}

func (*MemberNodeResponse) Descriptor deprecated

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

Deprecated: Use MemberNodeResponse.ProtoReflect.Descriptor instead.

func (*MemberNodeResponse) GetNode

func (x *MemberNodeResponse) GetNode() []*MemberNode

func (*MemberNodeResponse) ProtoMessage

func (*MemberNodeResponse) ProtoMessage()

func (*MemberNodeResponse) ProtoReflect

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

func (*MemberNodeResponse) Reset

func (x *MemberNodeResponse) Reset()

func (*MemberNodeResponse) String

func (x *MemberNodeResponse) String() string

type MemberStartRequest

type MemberStartRequest struct {

	// 版本号
	Version string `protobuf:"bytes,1,opt,name=Version,proto3" json:"Version,omitempty"`
	// 端口
	Port string `protobuf:"bytes,2,opt,name=Port,proto3" json:"Port,omitempty"`
	// inner port
	InnerPort string `protobuf:"bytes,3,opt,name=InnerPort,proto3" json:"InnerPort,omitempty"`
	// contains filtered or unexported fields
}

路由注册

func (*MemberStartRequest) Descriptor deprecated

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

Deprecated: Use MemberStartRequest.ProtoReflect.Descriptor instead.

func (*MemberStartRequest) GetInnerPort

func (x *MemberStartRequest) GetInnerPort() string

func (*MemberStartRequest) GetPort

func (x *MemberStartRequest) GetPort() string

func (*MemberStartRequest) GetVersion

func (x *MemberStartRequest) GetVersion() string

func (*MemberStartRequest) ProtoMessage

func (*MemberStartRequest) ProtoMessage()

func (*MemberStartRequest) ProtoReflect

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

func (*MemberStartRequest) Reset

func (x *MemberStartRequest) Reset()

func (*MemberStartRequest) String

func (x *MemberStartRequest) String() string

type MemberStartResponse

type MemberStartResponse struct {
	Node []*ServerNode `protobuf:"bytes,1,rep,name=Node,proto3" json:"Node,omitempty"`
	// contains filtered or unexported fields
}

func (*MemberStartResponse) Descriptor deprecated

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

Deprecated: Use MemberStartResponse.ProtoReflect.Descriptor instead.

func (*MemberStartResponse) GetNode

func (x *MemberStartResponse) GetNode() []*ServerNode

func (*MemberStartResponse) ProtoMessage

func (*MemberStartResponse) ProtoMessage()

func (*MemberStartResponse) ProtoReflect

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

func (*MemberStartResponse) Reset

func (x *MemberStartResponse) Reset()

func (*MemberStartResponse) String

func (x *MemberStartResponse) String() string

type MemberStopNotice

type MemberStopNotice struct {
	// contains filtered or unexported fields
}

路由关闭

func (*MemberStopNotice) Descriptor deprecated

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

Deprecated: Use MemberStopNotice.ProtoReflect.Descriptor instead.

func (*MemberStopNotice) ProtoMessage

func (*MemberStopNotice) ProtoMessage()

func (*MemberStopNotice) ProtoReflect

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

func (*MemberStopNotice) Reset

func (x *MemberStopNotice) Reset()

func (*MemberStopNotice) String

func (x *MemberStopNotice) String() string

type Msg

type Msg struct {

	// 通信SessionId
	Sid uint64 `protobuf:"varint,1,opt,name=Sid,proto3" json:"Sid,omitempty"`
	// 路由 模块_方法
	Route string `protobuf:"bytes,2,opt,name=Route,proto3" json:"Route,omitempty"`
	// 消息id
	Mid uint64 `protobuf:"varint,3,opt,name=Mid,proto3" json:"Mid,omitempty"`
	// 消息类型
	MsgType uint32 `protobuf:"varint,4,opt,name=MsgType,proto3" json:"MsgType,omitempty"`
	// data数据协议
	Deal uint32 `protobuf:"varint,5,opt,name=Deal,proto3" json:"Deal,omitempty"`
	// 数据
	Data []byte `protobuf:"bytes,6,opt,name=Data,proto3" json:"Data,omitempty"`
	// 版本号
	Version string `protobuf:"bytes,7,opt,name=Version,proto3" json:"Version,omitempty"`
	// contains filtered or unexported fields
}

消息

func (*Msg) Descriptor deprecated

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

Deprecated: Use Msg.ProtoReflect.Descriptor instead.

func (*Msg) GetData

func (x *Msg) GetData() []byte

func (*Msg) GetDeal

func (x *Msg) GetDeal() uint32

func (*Msg) GetMid

func (x *Msg) GetMid() uint64

func (*Msg) GetMsgType

func (x *Msg) GetMsgType() uint32

func (*Msg) GetRoute

func (x *Msg) GetRoute() string

func (*Msg) GetSid

func (x *Msg) GetSid() uint64

func (*Msg) GetVersion

func (x *Msg) GetVersion() string

func (*Msg) ProtoMessage

func (*Msg) ProtoMessage()

func (*Msg) ProtoReflect

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

func (*Msg) Reset

func (x *Msg) Reset()

func (*Msg) String

func (x *Msg) String() string

type Ping

type Ping struct {
	Psutil *Psutil `protobuf:"bytes,1,opt,name=Psutil,proto3" json:"Psutil,omitempty"`
	// contains filtered or unexported fields
}

心跳

func (*Ping) Descriptor deprecated

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

Deprecated: Use Ping.ProtoReflect.Descriptor instead.

func (*Ping) GetPsutil

func (x *Ping) GetPsutil() *Psutil

func (*Ping) ProtoMessage

func (*Ping) ProtoMessage()

func (*Ping) ProtoReflect

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

func (*Ping) Reset

func (x *Ping) Reset()

func (*Ping) String

func (x *Ping) String() string

type Pong

type Pong struct {
	Pong int64 `protobuf:"varint,1,opt,name=Pong,proto3" json:"Pong,omitempty"`
	// contains filtered or unexported fields
}

func (*Pong) Descriptor deprecated

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

Deprecated: Use Pong.ProtoReflect.Descriptor instead.

func (*Pong) GetPong

func (x *Pong) GetPong() int64

func (*Pong) ProtoMessage

func (*Pong) ProtoMessage()

func (*Pong) ProtoReflect

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

func (*Pong) Reset

func (x *Pong) Reset()

func (*Pong) String

func (x *Pong) String() string

type Psutil

type Psutil struct {

	// 内存
	MemTotal      uint64  `protobuf:"varint,1,opt,name=MemTotal,proto3" json:"MemTotal,omitempty"`
	MemAvailable  uint64  `protobuf:"varint,2,opt,name=MemAvailable,proto3" json:"MemAvailable,omitempty"`
	MemUsed       uint64  `protobuf:"varint,3,opt,name=MemUsed,proto3" json:"MemUsed,omitempty"`
	MemUsePercent float64 `protobuf:"fixed64,4,opt,name=MemUsePercent,proto3" json:"MemUsePercent,omitempty"`
	MemFree       uint64  `protobuf:"varint,5,opt,name=MemFree,proto3" json:"MemFree,omitempty"`
	// cpu
	CpuCores      int32   `protobuf:"varint,6,opt,name=CpuCores,proto3" json:"CpuCores,omitempty"`
	CpuModelName  string  `protobuf:"bytes,7,opt,name=CpuModelName,proto3" json:"CpuModelName,omitempty"`
	CpuUsePercent float64 `protobuf:"fixed64,8,opt,name=CpuUsePercent,proto3" json:"CpuUsePercent,omitempty"`
	// host
	HostName      string `protobuf:"bytes,9,opt,name=HostName,proto3" json:"HostName,omitempty"`
	HostBoostTime uint64 `protobuf:"varint,10,opt,name=HostBoostTime,proto3" json:"HostBoostTime,omitempty"`
	HostOs        string `protobuf:"bytes,11,opt,name=HostOs,proto3" json:"HostOs,omitempty"`
	HostPlatform  string `protobuf:"bytes,12,opt,name=HostPlatform,proto3" json:"HostPlatform,omitempty"`
	// contains filtered or unexported fields
}

内存数

func (*Psutil) Descriptor deprecated

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

Deprecated: Use Psutil.ProtoReflect.Descriptor instead.

func (*Psutil) GetCpuCores

func (x *Psutil) GetCpuCores() int32

func (*Psutil) GetCpuModelName

func (x *Psutil) GetCpuModelName() string

func (*Psutil) GetCpuUsePercent

func (x *Psutil) GetCpuUsePercent() float64

func (*Psutil) GetHostBoostTime

func (x *Psutil) GetHostBoostTime() uint64

func (*Psutil) GetHostName

func (x *Psutil) GetHostName() string

func (*Psutil) GetHostOs

func (x *Psutil) GetHostOs() string

func (*Psutil) GetHostPlatform

func (x *Psutil) GetHostPlatform() string

func (*Psutil) GetMemAvailable

func (x *Psutil) GetMemAvailable() uint64

func (*Psutil) GetMemFree

func (x *Psutil) GetMemFree() uint64

func (*Psutil) GetMemTotal

func (x *Psutil) GetMemTotal() uint64

func (*Psutil) GetMemUsePercent

func (x *Psutil) GetMemUsePercent() float64

func (*Psutil) GetMemUsed

func (x *Psutil) GetMemUsed() uint64

func (*Psutil) ProtoMessage

func (*Psutil) ProtoMessage()

func (*Psutil) ProtoReflect

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

func (*Psutil) Reset

func (x *Psutil) Reset()

func (*Psutil) String

func (x *Psutil) String() string

type ServerNode

type ServerNode struct {
	Version  string   `protobuf:"bytes,1,opt,name=Version,proto3" json:"Version,omitempty"`
	Addr     string   `protobuf:"bytes,2,opt,name=Addr,proto3" json:"Addr,omitempty"`
	LastTime int64    `protobuf:"varint,3,opt,name=LastTime,proto3" json:"LastTime,omitempty"`
	Routes   []string `protobuf:"bytes,4,rep,name=Routes,proto3" json:"Routes,omitempty"`
	Psutil   *Psutil  `protobuf:"bytes,5,opt,name=Psutil,proto3" json:"Psutil,omitempty"`
	// contains filtered or unexported fields
}

server node

func (*ServerNode) Descriptor deprecated

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

Deprecated: Use ServerNode.ProtoReflect.Descriptor instead.

func (*ServerNode) GetAddr

func (x *ServerNode) GetAddr() string

func (*ServerNode) GetLastTime

func (x *ServerNode) GetLastTime() int64

func (*ServerNode) GetPsutil

func (x *ServerNode) GetPsutil() *Psutil

func (*ServerNode) GetRoutes

func (x *ServerNode) GetRoutes() []string

func (*ServerNode) GetVersion

func (x *ServerNode) GetVersion() string

func (*ServerNode) ProtoMessage

func (*ServerNode) ProtoMessage()

func (*ServerNode) ProtoReflect

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

func (*ServerNode) Reset

func (x *ServerNode) Reset()

func (*ServerNode) String

func (x *ServerNode) String() string

type ServerNodeRequest

type ServerNodeRequest struct {
	// contains filtered or unexported fields
}

所有服务节点返回

func (*ServerNodeRequest) Descriptor deprecated

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

Deprecated: Use ServerNodeRequest.ProtoReflect.Descriptor instead.

func (*ServerNodeRequest) ProtoMessage

func (*ServerNodeRequest) ProtoMessage()

func (*ServerNodeRequest) ProtoReflect

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

func (*ServerNodeRequest) Reset

func (x *ServerNodeRequest) Reset()

func (*ServerNodeRequest) String

func (x *ServerNodeRequest) String() string

type ServerNodeResponse

type ServerNodeResponse struct {
	Node []*ServerNode `protobuf:"bytes,1,rep,name=node,proto3" json:"node,omitempty"`
	// contains filtered or unexported fields
}

func (*ServerNodeResponse) Descriptor deprecated

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

Deprecated: Use ServerNodeResponse.ProtoReflect.Descriptor instead.

func (*ServerNodeResponse) GetNode

func (x *ServerNodeResponse) GetNode() []*ServerNode

func (*ServerNodeResponse) ProtoMessage

func (*ServerNodeResponse) ProtoMessage()

func (*ServerNodeResponse) ProtoReflect

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

func (*ServerNodeResponse) Reset

func (x *ServerNodeResponse) Reset()

func (*ServerNodeResponse) String

func (x *ServerNodeResponse) String() string

type ServerStartRequest

type ServerStartRequest struct {

	// 版本号
	Version string `protobuf:"bytes,1,opt,name=Version,proto3" json:"Version,omitempty"`
	// 端口
	Port string `protobuf:"bytes,2,opt,name=Port,proto3" json:"Port,omitempty"`
	// 路由
	Routes []string `protobuf:"bytes,3,rep,name=Routes,proto3" json:"Routes,omitempty"`
	// contains filtered or unexported fields
}

服务节点启动

func (*ServerStartRequest) Descriptor deprecated

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

Deprecated: Use ServerStartRequest.ProtoReflect.Descriptor instead.

func (*ServerStartRequest) GetPort

func (x *ServerStartRequest) GetPort() string

func (*ServerStartRequest) GetRoutes

func (x *ServerStartRequest) GetRoutes() []string

func (*ServerStartRequest) GetVersion

func (x *ServerStartRequest) GetVersion() string

func (*ServerStartRequest) ProtoMessage

func (*ServerStartRequest) ProtoMessage()

func (*ServerStartRequest) ProtoReflect

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

func (*ServerStartRequest) Reset

func (x *ServerStartRequest) Reset()

func (*ServerStartRequest) String

func (x *ServerStartRequest) String() string

type ServerStartResponse

type ServerStartResponse struct {
	Node []*MemberNode `protobuf:"bytes,1,rep,name=node,proto3" json:"node,omitempty"`
	// contains filtered or unexported fields
}

func (*ServerStartResponse) Descriptor deprecated

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

Deprecated: Use ServerStartResponse.ProtoReflect.Descriptor instead.

func (*ServerStartResponse) GetNode

func (x *ServerStartResponse) GetNode() []*MemberNode

func (*ServerStartResponse) ProtoMessage

func (*ServerStartResponse) ProtoMessage()

func (*ServerStartResponse) ProtoReflect

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

func (*ServerStartResponse) Reset

func (x *ServerStartResponse) Reset()

func (*ServerStartResponse) String

func (x *ServerStartResponse) String() string

type ServerStopNotice

type ServerStopNotice struct {
	// contains filtered or unexported fields
}

服务节点关闭

func (*ServerStopNotice) Descriptor deprecated

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

Deprecated: Use ServerStopNotice.ProtoReflect.Descriptor instead.

func (*ServerStopNotice) ProtoMessage

func (*ServerStopNotice) ProtoMessage()

func (*ServerStopNotice) ProtoReflect

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

func (*ServerStopNotice) Reset

func (x *ServerStopNotice) Reset()

func (*ServerStopNotice) String

func (x *ServerStopNotice) String() string

type SessionCloseNotice

type SessionCloseNotice struct {
	Sid uint64 `protobuf:"varint,1,opt,name=Sid,proto3" json:"Sid,omitempty"`
	// contains filtered or unexported fields
}

func (*SessionCloseNotice) Descriptor deprecated

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

Deprecated: Use SessionCloseNotice.ProtoReflect.Descriptor instead.

func (*SessionCloseNotice) GetSid

func (x *SessionCloseNotice) GetSid() uint64

func (*SessionCloseNotice) ProtoMessage

func (*SessionCloseNotice) ProtoMessage()

func (*SessionCloseNotice) ProtoReflect

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

func (*SessionCloseNotice) Reset

func (x *SessionCloseNotice) Reset()

func (*SessionCloseNotice) String

func (x *SessionCloseNotice) String() string

type SessionInitNotice

type SessionInitNotice struct {
	Sid uint64 `protobuf:"varint,1,opt,name=Sid,proto3" json:"Sid,omitempty"`
	// contains filtered or unexported fields
}

func (*SessionInitNotice) Descriptor deprecated

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

Deprecated: Use SessionInitNotice.ProtoReflect.Descriptor instead.

func (*SessionInitNotice) GetSid

func (x *SessionInitNotice) GetSid() uint64

func (*SessionInitNotice) ProtoMessage

func (*SessionInitNotice) ProtoMessage()

func (*SessionInitNotice) ProtoReflect

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

func (*SessionInitNotice) Reset

func (x *SessionInitNotice) Reset()

func (*SessionInitNotice) String

func (x *SessionInitNotice) String() string

Jump to

Keyboard shortcuts

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