cproto

package
v1.0.2 Latest Latest
Warning

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

 Go to latest Published: Feb 23, 2026 License: MIT Imports: 9 Imported by: 0

README

// protoc-gen-go v1.31.0 // protoc v4.24.2

#1.安装protoc-gen-go go install google.golang.org/protobuf/cmd/protoc-gen-go@latest

#2.安装protoc 3.15.8版本 (支持optional, https://github.com/protocolbuffers/protobuf/releases/tag/v3.15.8) wget https://github.com/protocolbuffers/protobuf/releases/download/v3.15.8/protoc-3.15.8-linux-x86_64.zip unzip protoc-3.15.8-linux-x86_64.zip -d /usr/local chmod +x /usr/local/bin/protoc protoc --version

Documentation

Index

Constants

View Source 
const (
	MIDKey = "mid"
)

Variables

View Source 
var (
	PomeloBroadcast_PushType_name = map[int32]string{
		0: "AllUID",
		1: "UID",
	}
	PomeloBroadcast_PushType_value = map[string]int32{
		"AllUID": 0,
		"UID":    1,
	}
)

Enum value maps for PomeloBroadcast_PushType.

View Source 
var File_proto_proto protoreflect.FileDescriptor

Functions

This section is empty.

Types

type ClusterPacket 

type ClusterPacket struct {
	BuildTime  int64    `protobuf:"varint,1,opt,name=buildTime,proto3" json:"buildTime,omitempty"`
	SourcePath string   `protobuf:"bytes,2,opt,name=sourcePath,proto3" json:"sourcePath,omitempty"`
	TargetPath string   `protobuf:"bytes,3,opt,name=targetPath,proto3" json:"targetPath,omitempty"`
	FuncName   string   `protobuf:"bytes,4,opt,name=funcName,proto3" json:"funcName,omitempty"`
	ArgBytes   []byte   `protobuf:"bytes,5,opt,name=argBytes,proto3" json:"argBytes,omitempty"`
	Session    *Session `protobuf:"bytes,6,opt,name=session,proto3" json:"session,omitempty"`
	// contains filtered or unexported fields
}

func BuildClusterPacket 

func BuildClusterPacket(source, target, funcName string) *ClusterPacket

func GetClusterPacket 

func GetClusterPacket() *ClusterPacket

func UnmarshalPacket 

func UnmarshalPacket(data []byte) (*ClusterPacket, error)

func (*ClusterPacket) Descriptor deprecated 

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

Deprecated: Use ClusterPacket.ProtoReflect.Descriptor instead.

func (*ClusterPacket) GetArgBytes 

func (x *ClusterPacket) GetArgBytes() []byte

func (*ClusterPacket) GetBuildTime 

func (x *ClusterPacket) GetBuildTime() int64

func (*ClusterPacket) GetFuncName 

func (x *ClusterPacket) GetFuncName() string

func (*ClusterPacket) GetSession 

func (x *ClusterPacket) GetSession() *Session

func (*ClusterPacket) GetSourcePath 

func (x *ClusterPacket) GetSourcePath() string

func (*ClusterPacket) GetTargetPath 

func (x *ClusterPacket) GetTargetPath() string

func (*ClusterPacket) PrintLog 

func (x *ClusterPacket) PrintLog() string

func (*ClusterPacket) ProtoMessage 

func (*ClusterPacket) ProtoMessage()

func (*ClusterPacket) ProtoReflect 

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

func (*ClusterPacket) Recycle 

func (x *ClusterPacket) Recycle()

func (*ClusterPacket) Reset 

func (x *ClusterPacket) Reset()

func (*ClusterPacket) String 

func (x *ClusterPacket) String() string

type I32 

type I32 struct {
	Value int32 `protobuf:"varint,1,opt,name=value,proto3" json:"value,omitempty"`
	// contains filtered or unexported fields
}

func (*I32) Descriptor deprecated 

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

Deprecated: Use I32.ProtoReflect.Descriptor instead.

func (*I32) GetValue 

func (x *I32) GetValue() int32

func (*I32) ProtoMessage 

func (*I32) ProtoMessage()

func (*I32) ProtoReflect 

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

func (*I32) Reset 

func (x *I32) Reset()

func (*I32) String 

func (x *I32) String() string

type Member 

type Member struct {
	NodeID   string            `protobuf:"bytes,1,opt,name=nodeID,proto3" json:"nodeID,omitempty"`     // node id
	NodeType string            `protobuf:"bytes,2,opt,name=nodeType,proto3" json:"nodeType,omitempty"` // node type
	Address  string            `protobuf:"bytes,3,opt,name=address,proto3" json:"address,omitempty"`   // rpc ip address
	Settings map[string]string ``                                                                      // node settings data
	/* 157-byte string literal not displayed */
	LastAt           int64 `protobuf:"varint,5,opt,name=lastAt,proto3" json:"lastAt,omitempty"`                     // last check time
	HeartbeatTimeout int64 `protobuf:"varint,6,opt,name=heartbeatTimeout,proto3" json:"heartbeatTimeout,omitempty"` // The heartbeat timeout period (in milliseconds) for custom node configuration
	// contains filtered or unexported fields
}

member data

func (*Member) Descriptor deprecated 

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

Deprecated: Use Member.ProtoReflect.Descriptor instead.

func (*Member) GetAddress 

func (x *Member) GetAddress() string

func (*Member) GetHeartbeatTimeout 

func (x *Member) GetHeartbeatTimeout() int64

func (*Member) GetLastAt 

func (x *Member) GetLastAt() int64

func (*Member) GetNodeID 

func (x *Member) GetNodeID() string

func (*Member) GetNodeType 

func (x *Member) GetNodeType() string

func (*Member) GetSettings 

func (x *Member) GetSettings() map[string]string

func (*Member) IsTimeout 

func (x *Member) IsTimeout(nowMills int64) bool

func (*Member) ProtoMessage 

func (*Member) ProtoMessage()

func (*Member) ProtoReflect 

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

func (*Member) Reset 

func (x *Member) Reset()

func (*Member) String 

func (x *Member) String() string

type MemberList 

type MemberList struct {
	List []*Member `protobuf:"bytes,1,rep,name=list,proto3" json:"list,omitempty"`
	// contains filtered or unexported fields
}

member list data

func (*MemberList) Descriptor deprecated 

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

Deprecated: Use MemberList.ProtoReflect.Descriptor instead.

func (*MemberList) GetList 

func (x *MemberList) GetList() []*Member

func (*MemberList) ProtoMessage 

func (*MemberList) ProtoMessage()

func (*MemberList) ProtoReflect 

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

func (*MemberList) Reset 

func (x *MemberList) Reset()

func (*MemberList) String 

func (x *MemberList) String() string

type NodeID 

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

func (*NodeID) Descriptor deprecated 

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

Deprecated: Use NodeID.ProtoReflect.Descriptor instead.

func (*NodeID) GetValue 

func (x *NodeID) GetValue() string

func (*NodeID) ProtoMessage 

func (*NodeID) ProtoMessage()

func (*NodeID) ProtoReflect 

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

func (*NodeID) Reset 

func (x *NodeID) Reset()

func (*NodeID) String 

func (x *NodeID) String() string

type PomeloBroadcast 

type PomeloBroadcast struct {
	PushType PomeloBroadcast_PushType `protobuf:"varint,1,opt,name=pushType,proto3,enum=cproto.PomeloBroadcast_PushType" json:"pushType,omitempty"` // broadcast push type
	UidList  []int64                  `protobuf:"varint,2,rep,packed,name=uidList,proto3" json:"uidList,omitempty"`                                 // broadcast the uid list
	Route    string                   `protobuf:"bytes,3,opt,name=route,proto3" json:"route,omitempty"`                                             // push route
	Data     []byte                   `protobuf:"bytes,4,opt,name=data,proto3" json:"data,omitempty"`                                               // push data
	// contains filtered or unexported fields
}

func (*PomeloBroadcast) Descriptor deprecated 

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

Deprecated: Use PomeloBroadcast.ProtoReflect.Descriptor instead.

func (*PomeloBroadcast) GetData 

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

func (*PomeloBroadcast) GetPushType 

func (x *PomeloBroadcast) GetPushType() PomeloBroadcast_PushType

func (*PomeloBroadcast) GetRoute 

func (x *PomeloBroadcast) GetRoute() string

func (*PomeloBroadcast) GetUidList 

func (x *PomeloBroadcast) GetUidList() []int64

func (*PomeloBroadcast) ProtoMessage 

func (*PomeloBroadcast) ProtoMessage()

func (*PomeloBroadcast) ProtoReflect 

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

func (*PomeloBroadcast) Reset 

func (x *PomeloBroadcast) Reset()

func (*PomeloBroadcast) String 

func (x *PomeloBroadcast) String() string

type PomeloBroadcast_PushType 

type PomeloBroadcast_PushType int32
const (
	PomeloBroadcast_AllUID PomeloBroadcast_PushType = 0 // all agent with uid
	PomeloBroadcast_UID    PomeloBroadcast_PushType = 1 // uidList
)

func (PomeloBroadcast_PushType) Descriptor 

func (PomeloBroadcast_PushType) Descriptor() protoreflect.EnumDescriptor

func (PomeloBroadcast_PushType) Enum 

func (x PomeloBroadcast_PushType) Enum() *PomeloBroadcast_PushType

func (PomeloBroadcast_PushType) EnumDescriptor deprecated 

func (PomeloBroadcast_PushType) EnumDescriptor() ([]byte, []int)

Deprecated: Use PomeloBroadcast_PushType.Descriptor instead.

func (PomeloBroadcast_PushType) Number 

func (x PomeloBroadcast_PushType) Number() protoreflect.EnumNumber

func (PomeloBroadcast_PushType) String 

func (x PomeloBroadcast_PushType) String() string

func (PomeloBroadcast_PushType) Type 

func (PomeloBroadcast_PushType) Type() protoreflect.EnumType

type PomeloKick 

type PomeloKick struct {
	Sid    string `protobuf:"bytes,1,opt,name=sid,proto3" json:"sid,omitempty"`
	Uid    int64  `protobuf:"varint,2,opt,name=uid,proto3" json:"uid,omitempty"`
	Reason []byte `protobuf:"bytes,3,opt,name=reason,proto3" json:"reason,omitempty"`
	Close  bool   `protobuf:"varint,4,opt,name=close,proto3" json:"close,omitempty"`
	// contains filtered or unexported fields
}

func (*PomeloKick) Descriptor deprecated 

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

Deprecated: Use PomeloKick.ProtoReflect.Descriptor instead.

func (*PomeloKick) GetClose 

func (x *PomeloKick) GetClose() bool

func (*PomeloKick) GetReason 

func (x *PomeloKick) GetReason() []byte

func (*PomeloKick) GetSid 

func (x *PomeloKick) GetSid() string

func (*PomeloKick) GetUid 

func (x *PomeloKick) GetUid() int64

func (*PomeloKick) ProtoMessage 

func (*PomeloKick) ProtoMessage()

func (*PomeloKick) ProtoReflect 

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

func (*PomeloKick) Reset 

func (x *PomeloKick) Reset()

func (*PomeloKick) String 

func (x *PomeloKick) String() string

type PomeloPush 

type PomeloPush struct {
	Sid   string `protobuf:"bytes,1,opt,name=sid,proto3" json:"sid,omitempty"`
	Uid   int64  `protobuf:"varint,2,opt,name=uid,proto3" json:"uid,omitempty"`
	Route string `protobuf:"bytes,3,opt,name=route,proto3" json:"route,omitempty"`
	Data  []byte `protobuf:"bytes,4,opt,name=data,proto3" json:"data,omitempty"`
	// contains filtered or unexported fields
}

func (*PomeloPush) Descriptor deprecated 

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

Deprecated: Use PomeloPush.ProtoReflect.Descriptor instead.

func (*PomeloPush) GetData 

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

func (*PomeloPush) GetRoute 

func (x *PomeloPush) GetRoute() string

func (*PomeloPush) GetSid 

func (x *PomeloPush) GetSid() string

func (*PomeloPush) GetUid 

func (x *PomeloPush) GetUid() int64

func (*PomeloPush) ProtoMessage 

func (*PomeloPush) ProtoMessage()

func (*PomeloPush) ProtoReflect 

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

func (*PomeloPush) Reset 

func (x *PomeloPush) Reset()

func (*PomeloPush) String 

func (x *PomeloPush) String() string

type PomeloResponse 

type PomeloResponse struct {
	Sid  string `protobuf:"bytes,1,opt,name=sid,proto3" json:"sid,omitempty"`
	Mid  uint32 `protobuf:"varint,2,opt,name=mid,proto3" json:"mid,omitempty"` // message id build by client
	Data []byte `protobuf:"bytes,3,opt,name=data,proto3" json:"data,omitempty"`
	Code int32  `protobuf:"varint,4,opt,name=code,proto3" json:"code,omitempty"`
	// contains filtered or unexported fields
}

func (*PomeloResponse) Descriptor deprecated 

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

Deprecated: Use PomeloResponse.ProtoReflect.Descriptor instead.

func (*PomeloResponse) GetCode 

func (x *PomeloResponse) GetCode() int32

func (*PomeloResponse) GetData 

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

func (*PomeloResponse) GetMid 

func (x *PomeloResponse) GetMid() uint32

func (*PomeloResponse) GetSid 

func (x *PomeloResponse) GetSid() string

func (*PomeloResponse) ProtoMessage 

func (*PomeloResponse) ProtoMessage()

func (*PomeloResponse) ProtoReflect 

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

func (*PomeloResponse) Reset 

func (x *PomeloResponse) Reset()

func (*PomeloResponse) String 

func (x *PomeloResponse) String() string

type Response 

type Response struct {
	Code int32  `protobuf:"varint,1,opt,name=code,proto3" json:"code,omitempty"` // message code
	Data []byte `protobuf:"bytes,2,opt,name=data,proto3" json:"data,omitempty"`  // message data
	// contains filtered or unexported fields
}

cross node response data

func (*Response) Descriptor deprecated 

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

Deprecated: Use Response.ProtoReflect.Descriptor instead.

func (*Response) GetCode 

func (x *Response) GetCode() int32

func (*Response) GetData 

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

func (*Response) ProtoMessage 

func (*Response) ProtoMessage()

func (*Response) ProtoReflect 

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

func (*Response) Reset 

func (x *Response) Reset()

func (*Response) String 

func (x *Response) String() string

type Session 

type Session struct {
	Sid       string            `protobuf:"bytes,1,opt,name=sid,proto3" json:"sid,omitempty"`             // session unique id
	Uid       int64             `protobuf:"varint,2,opt,name=uid,proto3" json:"uid,omitempty"`            // user id
	AgentPath string            `protobuf:"bytes,3,opt,name=agentPath,proto3" json:"agentPath,omitempty"` // frontend actor agent path
	Ip        string            `protobuf:"bytes,4,opt,name=ip,proto3" json:"ip,omitempty"`               // ip address
	Data      map[string]string ``                                                                        // extend data
	/* 149-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*Session) ActorPath 

func (x *Session) ActorPath() string

func (*Session) Add 

func (x *Session) Add(key string, value interface{})

func (*Session) Clear 

func (x *Session) Clear()

Clear releases all settings related to current sc

func (*Session) Contains 

func (x *Session) Contains(key string) bool

func (*Session) Descriptor deprecated 

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

Deprecated: Use Session.ProtoReflect.Descriptor instead.

func (*Session) Equal 

func (x *Session) Equal(key, value string) bool

func (*Session) GetAgentPath 

func (x *Session) GetAgentPath() string

func (*Session) GetData 

func (x *Session) GetData() map[string]string

func (*Session) GetInt 

func (x *Session) GetInt(key string) int

func (*Session) GetInt32 

func (x *Session) GetInt32(key string) int32

GetInt32 returns the value associated with the key as a int32.

func (*Session) GetInt64 

func (x *Session) GetInt64(key string) int64

func (*Session) GetIp 

func (x *Session) GetIp() string

func (*Session) GetMID 

func (x *Session) GetMID() uint32

func (*Session) GetSid 

func (x *Session) GetSid() string

func (*Session) GetString 

func (x *Session) GetString(key string) string

GetString returns the value associated with the key as a string.

func (*Session) GetUid 

func (x *Session) GetUid() int64

func (*Session) GetUint 

func (x *Session) GetUint(key string) uint

func (*Session) ImportAll 

func (x *Session) ImportAll(data map[string]string)

func (*Session) IsBind 

func (x *Session) IsBind() bool

func (*Session) ProtoMessage 

func (*Session) ProtoMessage()

func (*Session) ProtoReflect 

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

func (*Session) Remove 

func (x *Session) Remove(key string)

func (*Session) Reset 

func (x *Session) Reset()

func (*Session) Restore 

func (x *Session) Restore(data map[string]string)

func (*Session) Set 

func (x *Session) Set(key string, value string)

func (*Session) SetMID 

func (x *Session) SetMID(mid uint32)

func (*Session) String 

func (x *Session) String() string

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.