msg

Documentation

Index

• Constants
• Variables
• type EdgeNode
  • func (x *EdgeNode) Clone() *EdgeNode
  • func (x *EdgeNode) DeepCopy(z *EdgeNode)
  • func (*EdgeNode) Descriptor() ([]byte, []int)
  • func (x *EdgeNode) GetGatewayAddr() []string
  • func (x *EdgeNode) GetHash() uint64
  • func (x *EdgeNode) GetReplicaSet() uint64
  • func (x *EdgeNode) GetServerID() []byte
  • func (x *EdgeNode) GetTunnelAddr() []string
  • func (x *EdgeNode) Marshal() ([]byte, error)
  • func (x *EdgeNode) MarshalJSON() ([]byte, error)
  • func (*EdgeNode) ProtoMessage()
  • func (x *EdgeNode) ProtoReflect() protoreflect.Message
  • func (x *EdgeNode) Reset()
  • func (x *EdgeNode) String() string
  • func (x *EdgeNode) Unmarshal(b []byte) error
  • func (x *EdgeNode) UnmarshalJSON(b []byte) error
• type TunnelMessage
  • func (x *TunnelMessage) Clone() *TunnelMessage
  • func (x *TunnelMessage) DeepCopy(z *TunnelMessage)
  • func (*TunnelMessage) Descriptor() ([]byte, []int)
  • func (x *TunnelMessage) Fill(senderID []byte, senderReplicaSet uint64, e *rony.MessageEnvelope, ...)
  • func (x *TunnelMessage) GetEnvelope() *rony.MessageEnvelope
  • func (x *TunnelMessage) GetSenderID() []byte
  • func (x *TunnelMessage) GetSenderReplicaSet() uint64
  • func (x *TunnelMessage) GetStore() []*rony.KeyValue
  • func (x *TunnelMessage) Marshal() ([]byte, error)
  • func (x *TunnelMessage) MarshalJSON() ([]byte, error)
  • func (*TunnelMessage) ProtoMessage()
  • func (x *TunnelMessage) ProtoReflect() protoreflect.Message
  • func (x *TunnelMessage) Reset()
  • func (x *TunnelMessage) String() string
  • func (x *TunnelMessage) Unmarshal(b []byte) error
  • func (x *TunnelMessage) UnmarshalJSON(b []byte) error

Constants

const C_EdgeNode uint64 = 12741646567456486228

const C_TunnelMessage uint64 = 12904103981552626014

Variables

var File_imsg_proto protoreflect.FileDescriptor

var PoolEdgeNode = poolEdgeNode{}

var PoolTunnelMessage = poolTunnelMessage{}

Types

type EdgeNode

type EdgeNode struct {
	ServerID    []byte   `protobuf:"bytes,1,opt,name=ServerID,proto3" json:"ServerID,omitempty"`
	ReplicaSet  uint64   `protobuf:"varint,2,opt,name=ReplicaSet,proto3" json:"ReplicaSet,omitempty"`
	Hash        uint64   `protobuf:"varint,3,opt,name=Hash,proto3" json:"Hash,omitempty"`
	GatewayAddr []string `protobuf:"bytes,7,rep,name=GatewayAddr,proto3" json:"GatewayAddr,omitempty"`
	TunnelAddr  []string `protobuf:"bytes,8,rep,name=TunnelAddr,proto3" json:"TunnelAddr,omitempty"`
	// contains filtered or unexported fields
}

EdgeNode

func (*EdgeNode) Clone

func (x *EdgeNode) Clone() *EdgeNode

func (*EdgeNode) DeepCopy

func (x *EdgeNode) DeepCopy(z *EdgeNode)

func (*EdgeNode) Descriptor

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

Deprecated: Use EdgeNode.ProtoReflect.Descriptor instead.

func (*EdgeNode) GetGatewayAddr

func (x *EdgeNode) GetGatewayAddr() []string

func (*EdgeNode) GetHash

func (x *EdgeNode) GetHash() uint64

func (*EdgeNode) GetReplicaSet

func (x *EdgeNode) GetReplicaSet() uint64

func (*EdgeNode) GetServerID

func (x *EdgeNode) GetServerID() []byte

func (*EdgeNode) GetTunnelAddr

func (x *EdgeNode) GetTunnelAddr() []string

func (*EdgeNode) Marshal

func (x *EdgeNode) Marshal() ([]byte, error)

func (*EdgeNode) MarshalJSON

func (x *EdgeNode) MarshalJSON() ([]byte, error)

func (*EdgeNode) ProtoMessage

func (*EdgeNode) ProtoMessage()

func (*EdgeNode) ProtoReflect

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

func (*EdgeNode) Reset

func (x *EdgeNode) Reset()

func (*EdgeNode) String

func (x *EdgeNode) String() string

func (*EdgeNode) Unmarshal

func (x *EdgeNode) Unmarshal(b []byte) error

func (*EdgeNode) UnmarshalJSON

func (x *EdgeNode) UnmarshalJSON(b []byte) error

type TunnelMessage

type TunnelMessage struct {
	SenderID         []byte                `protobuf:"bytes,1,opt,name=SenderID,proto3" json:"SenderID,omitempty"`
	SenderReplicaSet uint64                `protobuf:"varint,2,opt,name=SenderReplicaSet,proto3" json:"SenderReplicaSet,omitempty"`
	Store            []*rony.KeyValue      `protobuf:"bytes,3,rep,name=Store,proto3" json:"Store,omitempty"`
	Envelope         *rony.MessageEnvelope `protobuf:"bytes,4,opt,name=Envelope,proto3" json:"Envelope,omitempty"`
	// contains filtered or unexported fields
}

TunnelMessage

func (*TunnelMessage) Clone

func (x *TunnelMessage) Clone() *TunnelMessage

func (*TunnelMessage) DeepCopy

func (x *TunnelMessage) DeepCopy(z *TunnelMessage)

func (*TunnelMessage) Descriptor

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

Deprecated: Use TunnelMessage.ProtoReflect.Descriptor instead.

func (*TunnelMessage) Fill

func (x *TunnelMessage) Fill(senderID []byte, senderReplicaSet uint64, e *rony.MessageEnvelope, kvs ...*rony.KeyValue)

func (*TunnelMessage) GetEnvelope

func (x *TunnelMessage) GetEnvelope() *rony.MessageEnvelope

func (*TunnelMessage) GetSenderID

func (x *TunnelMessage) GetSenderID() []byte

func (*TunnelMessage) GetSenderReplicaSet

func (x *TunnelMessage) GetSenderReplicaSet() uint64

func (*TunnelMessage) GetStore

func (x *TunnelMessage) GetStore() []*rony.KeyValue

func (*TunnelMessage) Marshal

func (x *TunnelMessage) Marshal() ([]byte, error)

func (*TunnelMessage) MarshalJSON

func (x *TunnelMessage) MarshalJSON() ([]byte, error)

func (*TunnelMessage) ProtoMessage

func (*TunnelMessage) ProtoMessage()

func (*TunnelMessage) ProtoReflect

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

func (*TunnelMessage) Reset

func (x *TunnelMessage) Reset()

func (*TunnelMessage) String

func (x *TunnelMessage) String() string

func (*TunnelMessage) Unmarshal

func (x *TunnelMessage) Unmarshal(b []byte) error

func (*TunnelMessage) UnmarshalJSON

func (x *TunnelMessage) UnmarshalJSON(b []byte) error