msg

package
v0.12.36 Latest Latest
Warning

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

 Go to latest Published: Sep 2, 2021 License: BSD-3-Clause Imports: 14 Imported by: 0

Documentation

Index

Constants

View Source 
const C_EdgeNode uint64 = 12741646567456486228
View Source 
const C_GetPage uint64 = 3661906127733581696
View Source 
const C_Page uint64 = 3661906127056011264
View Source 
const C_TunnelMessage uint64 = 12904103981552626014

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

This section is empty.

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

func (x *EdgeNode) Clone() *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) Clone added in v0.12.0 

func (x *GetPage) Clone() *GetPage

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 (*Page) Clone added in v0.12.0 

func (x *Page) Clone() *Page

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

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

func NewPageLocalRepo added in v0.12.0 

func NewPageLocalRepo(s *store.Store) *PageLocalRepo

func (*PageLocalRepo) Create added in v0.12.0 

func (r *PageLocalRepo) Create(m *Page) error

func (*PageLocalRepo) CreateWithTxn added in v0.12.0 

func (r *PageLocalRepo) CreateWithTxn(txn *rony.StoreTxn, alloc *tools.Allocator, m *Page) (err error)

func (*PageLocalRepo) Delete added in v0.12.0 

func (r *PageLocalRepo) Delete(id uint32) error

func (*PageLocalRepo) DeleteWithTxn added in v0.12.0 

func (r *PageLocalRepo) DeleteWithTxn(txn *rony.StoreTxn, alloc *tools.Allocator, id uint32) error

func (*PageLocalRepo) Iter added in v0.12.0 

func (r *PageLocalRepo) Iter(
	pk PagePrimaryKey, ito *store.IterOption, cb func(m *Page) bool,
) error

func (*PageLocalRepo) IterWithTxn added in v0.12.0 

func (r *PageLocalRepo) IterWithTxn(
	txn *rony.StoreTxn, alloc *tools.Allocator, offset PagePrimaryKey, ito *store.IterOption, cb func(m *Page) bool,
) error

func (*PageLocalRepo) List added in v0.12.0 

func (r *PageLocalRepo) List(
	pk PagePrimaryKey, lo *store.ListOption, cond func(m *Page) bool,
) ([]*Page, error)

func (*PageLocalRepo) ListWithTxn added in v0.12.0 

func (r *PageLocalRepo) ListWithTxn(
	txn *rony.StoreTxn, alloc *tools.Allocator, offset PagePrimaryKey, lo *store.ListOption, cond func(m *Page) bool,
) ([]*Page, error)

func (*PageLocalRepo) Read added in v0.12.0 

func (r *PageLocalRepo) Read(id uint32, m *Page) (*Page, error)

func (*PageLocalRepo) ReadByReplicaSetID added in v0.12.0 

func (r *PageLocalRepo) ReadByReplicaSetID(replicaSet uint64, id uint32, m *Page) (*Page, error)

func (*PageLocalRepo) ReadByReplicaSetIDWithTxn added in v0.12.0 

func (r *PageLocalRepo) ReadByReplicaSetIDWithTxn(
	txn *rony.StoreTxn, alloc *tools.Allocator,
	replicaSet uint64, id uint32, m *Page,
) (*Page, error)

func (*PageLocalRepo) ReadWithTxn added in v0.12.0 

func (r *PageLocalRepo) ReadWithTxn(txn *rony.StoreTxn, alloc *tools.Allocator, id uint32, m *Page) (*Page, error)

func (*PageLocalRepo) Save added in v0.12.0 

func (r *PageLocalRepo) Save(m *Page) error

func (*PageLocalRepo) SaveWithTxn added in v0.12.0 

func (r *PageLocalRepo) SaveWithTxn(txn *rony.StoreTxn, alloc *tools.Allocator, m *Page) (err error)

func (*PageLocalRepo) Update added in v0.12.0 

func (r *PageLocalRepo) Update(id uint32, m *Page) error

func (*PageLocalRepo) UpdateWithTxn added in v0.12.0 

func (r *PageLocalRepo) UpdateWithTxn(txn *rony.StoreTxn, alloc *tools.Allocator, m *Page) error

type PagePK added in v0.12.0 

type PagePK struct {
	ID uint32
}

type PagePrimaryKey added in v0.12.2 

type PagePrimaryKey interface {
	// contains filtered or unexported methods
}

type PageReplicaSetIDPK added in v0.12.0 

type PageReplicaSetIDPK struct {
	ReplicaSet uint64
	ID         uint32
}

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

func (x *TunnelMessage) Clone() *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.