msg

package
v0.10.5 Latest Latest
Warning

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

 Go to latest Published: Jul 5, 2021 License: BSD-3-Clause Imports: 10 Imported by: 0

Documentation

Index

Constants

View Source 
const C_EdgeNode int64 = 999040174
View Source 
const C_GetPage int64 = 3721890413
View Source 
const C_Page int64 = 3023575326
View Source 
const C_TunnelMessage int64 = 3271476222

Variables

View Source 
var File_imsg_proto protoreflect.FileDescriptor
View Source 
var PoolEdgeNode = poolEdgeNode{}
View Source 
var PoolGetPage = poolGetPage{}
View Source 
var PoolPage = poolPage{}
View Source 
var PoolTunnelMessage = poolTunnelMessage{}

Functions

func CreatePage 

func CreatePage(m *Page) error

func CreatePageWithTxn 

func CreatePageWithTxn(txn *rony.StoreLocalTxn, alloc *tools.Allocator, m *Page) (err error)

func DeletePage 

func DeletePage(id uint32) error

func DeletePageWithTxn 

func DeletePageWithTxn(txn *rony.StoreLocalTxn, alloc *tools.Allocator, id uint32) error

func IterPageByReplicaSet 

func IterPageByReplicaSet(txn *rony.StoreLocalTxn, alloc *tools.Allocator, replicaSet uint64, cb func(m *Page) bool) error

func IterPages 

func IterPages(txn *rony.StoreLocalTxn, alloc *tools.Allocator, cb func(m *Page) bool, orderBy ...PageOrder) error

func SavePage 

func SavePage(m *Page) error

func SavePageWithTxn 

func SavePageWithTxn(txn *rony.StoreLocalTxn, alloc *tools.Allocator, m *Page) (err error)

func UpdatePage 

func UpdatePage(id uint32, m *Page) error

func UpdatePageWithTxn 

func UpdatePageWithTxn(txn *rony.StoreLocalTxn, alloc *tools.Allocator, m *Page) error

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) DeepCopy 

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

func (*EdgeNode) Descriptor deprecated 

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 added in v0.10.3 

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 added in v0.10.3 

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

type GetPage 

type GetPage struct {
	PageID     uint32 `protobuf:"varint,1,opt,name=PageID,proto3" json:"PageID,omitempty"`
	ReplicaSet uint64 `protobuf:"varint,2,opt,name=ReplicaSet,proto3" json:"ReplicaSet,omitempty"`
	// contains filtered or unexported fields
}

GetPage @Function @Return: Page

func (*GetPage) DeepCopy 

func (x *GetPage) DeepCopy(z *GetPage)

func (*GetPage) Descriptor deprecated 

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

Deprecated: Use GetPage.ProtoReflect.Descriptor instead.

func (*GetPage) GetPageID 

func (x *GetPage) GetPageID() uint32

func (*GetPage) GetReplicaSet 

func (x *GetPage) GetReplicaSet() uint64

func (*GetPage) Marshal 

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

func (*GetPage) MarshalJSON added in v0.10.3 

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

func (*GetPage) ProtoMessage 

func (*GetPage) ProtoMessage()

func (*GetPage) ProtoReflect 

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

func (*GetPage) Reset 

func (x *GetPage) Reset()

func (*GetPage) String 

func (x *GetPage) String() string

func (*GetPage) Unmarshal 

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

func (*GetPage) UnmarshalJSON added in v0.10.3 

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

type Page 

type Page struct {
	ID         uint32 `protobuf:"varint,1,opt,name=ID,proto3" json:"ID,omitempty"`
	ReplicaSet uint64 `protobuf:"varint,2,opt,name=ReplicaSet,proto3" json:"ReplicaSet,omitempty"`
	// contains filtered or unexported fields
}

Page

func ListPage 

func ListPage(
	offsetID uint32, lo *store.ListOption, cond func(m *Page) bool, orderBy ...PageOrder,
) ([]*Page, error)

func ListPageByReplicaSet 

func ListPageByReplicaSet(
	replicaSet uint64, offsetID uint32, lo *store.ListOption, cond func(m *Page) bool,
) ([]*Page, error)

func ReadPage 

func ReadPage(id uint32, m *Page) (*Page, error)

func ReadPageByReplicaSetAndID 

func ReadPageByReplicaSetAndID(replicaSet uint64, id uint32, m *Page) (*Page, error)

func ReadPageByReplicaSetAndIDWithTxn 

func ReadPageByReplicaSetAndIDWithTxn(txn *rony.StoreLocalTxn, alloc *tools.Allocator, replicaSet uint64, id uint32, m *Page) (*Page, error)

func ReadPageWithTxn 

func ReadPageWithTxn(txn *rony.StoreLocalTxn, alloc *tools.Allocator, id uint32, m *Page) (*Page, error)

func (*Page) DeepCopy 

func (x *Page) DeepCopy(z *Page)

func (*Page) Descriptor deprecated 

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

Deprecated: Use Page.ProtoReflect.Descriptor instead.

func (*Page) GetID 

func (x *Page) GetID() uint32

func (*Page) GetReplicaSet 

func (x *Page) GetReplicaSet() uint64

func (*Page) Marshal 

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

func (*Page) MarshalJSON added in v0.10.3 

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

func (*Page) ProtoMessage 

func (*Page) ProtoMessage()

func (*Page) ProtoReflect 

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

func (*Page) Reset 

func (x *Page) Reset()

func (*Page) String 

func (x *Page) String() string

func (*Page) Unmarshal 

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

func (*Page) UnmarshalJSON added in v0.10.3 

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

type PageOrder 

type PageOrder string
const PageOrderByReplicaSet PageOrder = "ReplicaSet"

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) DeepCopy 

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

func (*TunnelMessage) Descriptor deprecated 

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 added in v0.10.3 

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 added in v0.10.3 

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

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.