rony

Jan 2, 2022

Changes in this version

type RestConn

+ Host func() string

Dec 28, 2021

Changes in this version

type RestConn

+ RequestURI func() string

Dec 28, 2021

Changes in this version

type RestConn

+ Schema func() string

Dec 26, 2021

Changes in this version

type Conn

+ Walk func(func(k string, v interface{}) bool)

Dec 9, 2021

Changes in this version

type RestConn

+ RedirectURL func(statusCode int, newURL string)

Nov 26, 2021

Changes in this version

+ type IMessage interface

type MessageEnvelope

+ JsonEncoded bool

+ func (x *MessageEnvelope) GetJsonEncoded() bool

+ type MessageEnvelopeJSON struct

+ Constructor string

+ Header map[string]string

+ Message json.RawMessage

+ RequestID uint64

Nov 24, 2021

Changes in this version

+ var E_RonyEnvelope = &file_options_proto_extTypes[5]

+ var E_RonySkipJson = &file_options_proto_extTypes[6]

Nov 23, 2021

Changes in this version

type Gateway

+ Subscribe func(d GatewayDelegate)

+ type GatewayDelegate interface

+ OnClose func(c Conn)

+ OnConnect func(c Conn, kvs ...*KeyValue)

+ OnMessage func(c Conn, streamID int64, data []byte)

type MessageEnvelope

+ func (x *MessageEnvelope) Append(key, val string)

+ func (x *MessageEnvelope) Carrier() *envelopeCarrier

Nov 17, 2021

Changes in this version

+ var E_RonyIsEnvelope = &file_options_proto_extTypes[5]

Nov 4, 2021

Changes in this version

+ var E_RonyCli = &file_options_proto_extTypes[0]

+ var E_RonyJsonUnwrap = &file_options_proto_extTypes[5]

+ type CliOpt struct

+ Protocol *string

+ func (*CliOpt) Descriptor() ([]byte, []int)

+ func (*CliOpt) ProtoMessage()

+ func (x *CliOpt) GetProtocol() string

+ func (x *CliOpt) ProtoReflect() protoreflect.Message

+ func (x *CliOpt) Reset()

+ func (x *CliOpt) String() string

+ type ModelOpt struct

+ GlobalDatasource *string

+ LocalDatasource *string

+ Singleton *bool

+ Table *PrimaryKeyOpt

+ View []*PrimaryKeyOpt

+ func (*ModelOpt) Descriptor() ([]byte, []int)

+ func (*ModelOpt) ProtoMessage()

+ func (x *ModelOpt) GetGlobalDatasource() string

+ func (x *ModelOpt) GetLocalDatasource() string

+ func (x *ModelOpt) GetSingleton() bool

+ func (x *ModelOpt) GetTable() *PrimaryKeyOpt

+ func (x *ModelOpt) GetView() []*PrimaryKeyOpt

+ func (x *ModelOpt) ProtoReflect() protoreflect.Message

+ func (x *ModelOpt) Reset()

+ func (x *ModelOpt) String() string

Nov 3, 2021

Changes in this version

type RestOpt

+ BindPathParam []string

+ BindQueryParam []string

+ func (x *RestOpt) GetBindPathParam() []string

+ func (x *RestOpt) GetBindQueryParam() []string

Oct 19, 2021

Changes in this version

type RestConn

+ ReadHeader func(key string) string

Sep 9, 2021

Changes in this version

type MessageContainer

+ SyncRun bool

+ func (x *MessageContainer) GetSyncRun() bool

+ type Router interface

+ Get func(entityID string) (replicaSet uint64, err error)

+ Set func(entityID string, replicaSet uint64, replace bool) error

Sep 7, 2021

Changes in this version

+ const C_Ping

+ const C_Pong

+ var PoolPing = poolPing

+ var PoolPong = poolPong

+ type Ping struct

+ ID int64

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

+ func (*Ping) ProtoMessage()

+ func (x *Ping) Clone() *Ping

+ func (x *Ping) DeepCopy(z *Ping)

+ func (x *Ping) GetID() int64

+ func (x *Ping) Marshal() ([]byte, error)

+ func (x *Ping) MarshalJSON() ([]byte, error)

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

+ func (x *Ping) Reset()

+ func (x *Ping) String() string

+ func (x *Ping) Unmarshal(b []byte) error

+ func (x *Ping) UnmarshalJSON(b []byte) error

+ type Pong struct

+ ID int64

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

+ func (*Pong) ProtoMessage()

+ func (x *Pong) Clone() *Pong

+ func (x *Pong) DeepCopy(z *Pong)

+ func (x *Pong) GetID() int64

+ func (x *Pong) Marshal() ([]byte, error)

+ func (x *Pong) MarshalJSON() ([]byte, error)

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

+ func (x *Pong) Reset()

+ func (x *Pong) String() string

+ func (x *Pong) Unmarshal(b []byte) error

+ func (x *Pong) UnmarshalJSON(b []byte) error

Sep 7, 2021

Changes in this version

+ var E_RonyDefault = &file_options_proto_extTypes[12]

+ var E_RonyHelp = &file_options_proto_extTypes[11]

Sep 5, 2021

Changes in this version

type MessageEnvelope

+ func (x *MessageEnvelope) Unwrap() (protoreflect.Message, error)

Sep 1, 2021

Changes in this version

+ var E_RonyGlobalRepo = &file_options_proto_extTypes[6]

Jul 21, 2021

Changes in this version

type Cluster

+ Leave func() error

Jul 18, 2021

Changes in this version

type RestConn

+ Redirect func(statusCode int, newHostPort string)

Jul 16, 2021

Changes in this version

+ var E_RonyLocalRepo = &file_options_proto_extTypes[5]

+ var E_RonyRemoteRepo = &file_options_proto_extTypes[6]

Jul 15, 2021

Changes in this version

+ type LocalDB = badger.DB

type Store

+ LocalDB func() *LocalDB

Jul 14, 2021

Changes in this version

type Edge

+ func (x *Edge) Clone() *Edge

type Edges

+ func (x *Edges) Clone() *Edges

type Error

+ func (x *Error) Clone() *Error

type GetAllNodes

+ func (x *GetAllNodes) Clone() *GetAllNodes

type GetNodes

+ func (x *GetNodes) Clone() *GetNodes

type HttpBody

+ func (x *HttpBody) Clone() *HttpBody

type KeyValue

+ func (x *KeyValue) Clone() *KeyValue

type MessageContainer

+ func (x *MessageContainer) Clone() *MessageContainer

+ type MountKey interface

+ type PrimaryKeyOpt struct

+ Alias *string

+ PartKey []string

+ SortKey []string

+ func (*PrimaryKeyOpt) Descriptor() ([]byte, []int)

+ func (*PrimaryKeyOpt) ProtoMessage()

+ func (x *PrimaryKeyOpt) GetAlias() string

+ func (x *PrimaryKeyOpt) GetPartKey() []string

+ func (x *PrimaryKeyOpt) GetSortKey() []string

+ func (x *PrimaryKeyOpt) ProtoReflect() protoreflect.Message

+ func (x *PrimaryKeyOpt) Reset()

+ func (x *PrimaryKeyOpt) String() string

type Redirect

+ func (x *Redirect) Clone() *Redirect

Jul 5, 2021

Changes in this version

type RestConn

+ WriteStatus func(status int)

Jul 4, 2021

Changes in this version

+ var E_RonyRest = &file_options_proto_extTypes[4]

type Edge

+ func (x *Edge) MarshalJSON() ([]byte, error)

+ func (x *Edge) UnmarshalJSON(b []byte) error

type Edges

+ func (x *Edges) MarshalJSON() ([]byte, error)

+ func (x *Edges) UnmarshalJSON(b []byte) error

type Error

+ func (x *Error) MarshalJSON() ([]byte, error)

+ func (x *Error) UnmarshalJSON(b []byte) error

type GetAllNodes

+ func (x *GetAllNodes) MarshalJSON() ([]byte, error)

+ func (x *GetAllNodes) UnmarshalJSON(b []byte) error

type GetNodes

+ func (x *GetNodes) MarshalJSON() ([]byte, error)

+ func (x *GetNodes) UnmarshalJSON(b []byte) error

type HttpBody

+ func (x *HttpBody) MarshalJSON() ([]byte, error)

+ func (x *HttpBody) UnmarshalJSON(b []byte) error

type KeyValue

+ func (x *KeyValue) MarshalJSON() ([]byte, error)

+ func (x *KeyValue) UnmarshalJSON(b []byte) error

+ type LogLevel = log.Level

type MessageContainer

+ func (x *MessageContainer) MarshalJSON() ([]byte, error)

+ func (x *MessageContainer) UnmarshalJSON(b []byte) error

type MessageEnvelope

+ func (x *MessageEnvelope) MarshalJSON() ([]byte, error)

+ func (x *MessageEnvelope) UnmarshalJSON(b []byte) error

type Redirect

+ func (x *Redirect) MarshalJSON() ([]byte, error)

+ func (x *Redirect) UnmarshalJSON(b []byte) error

+ type RestOpt struct

+ BindVariables *string

+ JsonEncode *bool

+ Method *string

+ Path *string

+ func (*RestOpt) Descriptor() ([]byte, []int)

+ func (*RestOpt) ProtoMessage()

+ func (x *RestOpt) GetBindVariables() string

+ func (x *RestOpt) GetJsonEncode() bool

+ func (x *RestOpt) GetMethod() string

+ func (x *RestOpt) GetPath() string

+ func (x *RestOpt) ProtoReflect() protoreflect.Message

+ func (x *RestOpt) Reset()

+ func (x *RestOpt) String() string

Jul 3, 2021

Changes in this version

type Conn

+ WriteBinary func(streamID int64, data []byte) error

+ type RestConn interface

+ Body func() []byte

+ Method func() string

+ MultiPart func() (*multipart.Form, error)

+ Path func() string

+ WriteHeader func(key, value string)

Jul 2, 2021

Changes in this version

+ const MethodConnect

+ const MethodDelete

+ const MethodGet

+ const MethodHead

+ const MethodOptions

+ const MethodPatch

+ const MethodPost

+ const MethodPut

+ const MethodTrace

+ const MethodWild

type Cluster

+ Addr func() string

+ Join func(addr ...string) (int, error)

+ MemberByHash func(uint64) ClusterMember

+ MemberByID func(string) ClusterMember

+ Members func() []ClusterMember

+ MembersByReplicaSet func(replicaSets ...uint64) []ClusterMember

+ ReplicaSet func() uint64

+ ServerID func() []byte

+ SetGatewayAddrs func(hostPorts []string) error

+ SetTunnelAddrs func(hostPorts []string) error

+ Shutdown func()

+ Start func()

+ Subscribe func(d ClusterDelegate)

+ TotalReplicas func() int

+ type ClusterDelegate interface

+ OnJoin func(hash uint64)

+ OnLeave func(hash uint64)

+ type ClusterMember interface

+ Dial func() (net.Conn, error)

+ GatewayAddr func() []string

+ Proto func(info *Edge) *Edge

+ ReplicaSet func() uint64

+ ServerID func() string

+ TunnelAddr func() []string

type Gateway

+ Addr func() []string

+ GetConn func(connID uint64) Conn

+ Protocol func() GatewayProtocol

+ Run func()

+ Shutdown func()

+ Start func()

+ type GatewayProtocol int32

+ const Dummy

+ const Grpc

+ const Http

+ const Quic

+ const TCP

+ const Undefined

+ const Websocket

+ func (p GatewayProtocol) String() string

+ type Store interface

+ Shutdown func()

+ Update func(fn func(StoreTxn) error) error

+ UpdateLocal func(fn func(txn *StoreLocalTxn) error) error

+ View func(fn func(StoreTxn) error) error

+ ViewLocal func(fn func(txn *StoreLocalTxn) error) error

+ type StoreLocalTxn = badger.Txn

+ type StoreTxn interface

+ Delete func(alloc *tools.Allocator, keyParts ...interface{}) error

+ Exists func(alloc *tools.Allocator, keyParts ...interface{}) bool

+ Get func(alloc *tools.Allocator, keyParts ...interface{}) ([]byte, error)

+ Set func(alloc *tools.Allocator, val []byte, keyParts ...interface{}) error

type Tunnel

+ Addr func() []string

+ Run func()

+ Shutdown func()

+ Start func()

Jun 30, 2021

Changes in this version

+ type Cluster = cluster.Cluster

+ type Gateway = gateway.Gateway

+ type GatewayBodyWriter = gateway.BodyWriter

+ type GatewayHeaderWriter = gateway.HeaderWriter

+ type Tunnel = tunnel.Tunnel

Jun 9, 2021

Changes in this version

+ type PageOrder string

+ const PageOrderByReplicaSet

May 21, 2021

Changes in this version

+ const C_HttpBody

+ var PoolHttpBody = poolHttpBody

type Error

+ func (x *Error) Expand() (string, string)

+ func (x *Error) ToEnvelope(me *MessageEnvelope)

+ type HttpBody struct

+ Body []byte

+ ContentType string

+ Header []*KeyValue

+ func (*HttpBody) Descriptor() ([]byte, []int)

+ func (*HttpBody) ProtoMessage()

+ func (x *HttpBody) DeepCopy(z *HttpBody)

+ func (x *HttpBody) GetBody() []byte

+ func (x *HttpBody) GetContentType() string

+ func (x *HttpBody) GetHeader() []*KeyValue

+ func (x *HttpBody) Marshal() ([]byte, error)

+ func (x *HttpBody) ProtoReflect() protoreflect.Message

+ func (x *HttpBody) Reset()

+ func (x *HttpBody) String() string

+ func (x *HttpBody) Unmarshal(b []byte) error

May 18, 2021

Changes in this version

+ const C_GetAllNodes

+ const C_StoreMessage

+ var PoolGetAllNodes = poolGetAllNodes

+ var PoolStoreMessage = poolStoreMessage

type EdgeNode

+ Hash uint64

+ func (x *EdgeNode) GetHash() uint64

+ type GetAllNodes struct

+ func (*GetAllNodes) Descriptor() ([]byte, []int)

+ func (*GetAllNodes) ProtoMessage()

+ func (x *GetAllNodes) DeepCopy(z *GetAllNodes)

+ func (x *GetAllNodes) Marshal() ([]byte, error)

+ func (x *GetAllNodes) ProtoReflect() protoreflect.Message

+ func (x *GetAllNodes) Reset()

+ func (x *GetAllNodes) String() string

+ func (x *GetAllNodes) Unmarshal(b []byte) error

+ type StoreMessage struct

+ Dummy bool

+ func (*StoreMessage) Descriptor() ([]byte, []int)

+ func (*StoreMessage) ProtoMessage()

+ func (x *StoreMessage) DeepCopy(z *StoreMessage)

+ func (x *StoreMessage) GetDummy() bool

+ func (x *StoreMessage) Marshal() ([]byte, error)

+ func (x *StoreMessage) ProtoReflect() protoreflect.Message

+ func (x *StoreMessage) Reset()

+ func (x *StoreMessage) String() string

+ func (x *StoreMessage) Unmarshal(b []byte) error

May 16, 2021

Changes in this version

type Redirect

+ Edges []*Edge

+ func (x *Redirect) GetEdges() []*Edge

Apr 21, 2021

Changes in this version

type Conn

+ ByPassDispatcher func() bool

Mar 12, 2021

Changes in this version

type MessageContainer

+ func (x *MessageContainer) Add(reqID uint64, constructor int64, p proto.Message, kvs ...*KeyValue)

Mar 1, 2021

Changes in this version

+ func CreatePage(m *Page) error

+ func CreatePageWithTxn(txn *store.Txn, alloc *store.Allocator, m *Page) (err error)

+ func UpdatePage(id uint32, m *Page) error

+ func UpdatePageWithTxn(txn *store.Txn, alloc *store.Allocator, m *Page) error

Feb 13, 2021

Changes in this version

+ func RegisterPrometheus(registerer prometheus.Registerer)

Feb 10, 2021

Changes in this version

+ const C_Edge

+ const C_Edges

+ const C_GetPage

+ const C_Page

+ var E_RonyNoClient = &file_options_proto_extTypes[2]

+ var ErrAlreadyExists = errors.New("already exists")

+ var PoolEdge = poolEdge

+ var PoolEdges = poolEdges

+ var PoolGetPage = poolGetPage

+ var PoolPage = poolPage

+ func DeletePage(id uint32) error

+ func DeletePageWithTxn(txn *badger.Txn, alloc *store.Allocator, id uint32) error

+ func IterPageByReplicaSet(txn *badger.Txn, alloc *store.Allocator, replicaSet uint64, ...) error

+ func IterPages(txn *badger.Txn, alloc *store.Allocator, cb func(m *Page) bool) error

+ func SavePage(m *Page) error

+ func SavePageWithTxn(txn *badger.Txn, alloc *store.Allocator, m *Page) (err error)

+ type Edge struct

+ HostPorts []string

+ Leader bool

+ ReplicaSet uint64

+ ServerID string

+ func (*Edge) Descriptor() ([]byte, []int)

+ func (*Edge) ProtoMessage()

+ func (x *Edge) DeepCopy(z *Edge)

+ func (x *Edge) GetHostPorts() []string

+ func (x *Edge) GetLeader() bool

+ func (x *Edge) GetReplicaSet() uint64

+ func (x *Edge) GetServerID() string

+ func (x *Edge) Marshal() ([]byte, error)

+ func (x *Edge) ProtoReflect() protoreflect.Message

+ func (x *Edge) Reset()

+ func (x *Edge) String() string

+ func (x *Edge) Unmarshal(b []byte) error

+ type Edges struct

+ Nodes []*Edge

+ func (*Edges) Descriptor() ([]byte, []int)

+ func (*Edges) ProtoMessage()

+ func (x *Edges) DeepCopy(z *Edges)

+ func (x *Edges) GetNodes() []*Edge

+ func (x *Edges) Marshal() ([]byte, error)

+ func (x *Edges) ProtoReflect() protoreflect.Message

+ func (x *Edges) Reset()

+ func (x *Edges) String() string

+ func (x *Edges) Unmarshal(b []byte) error

type Error

+ Description string

+ func (x *Error) GetDescription() string

+ type GetPage struct

+ PageID uint32

+ ReplicaSet uint64

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

+ func (*GetPage) ProtoMessage()

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

+ func (x *GetPage) GetPageID() uint32

+ func (x *GetPage) GetReplicaSet() uint64

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

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

+ func (x *GetPage) Reset()

+ func (x *GetPage) String() string

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

+ type Page struct

+ ID uint32

+ ReplicaSet uint64

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

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

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

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

+ func ReadPageByReplicaSetAndIDWithTxn(txn *badger.Txn, alloc *store.Allocator, replicaSet uint64, id uint32, m *Page) (*Page, error)

+ func ReadPageWithTxn(txn *badger.Txn, alloc *store.Allocator, id uint32, m *Page) (*Page, error)

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

+ func (*Page) ProtoMessage()

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

+ func (x *Page) GetID() uint32

+ func (x *Page) GetReplicaSet() uint64

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

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

+ func (x *Page) Reset()

+ func (x *Page) String() string

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

Feb 8, 2021

Changes in this version

+ var E_RonyInconsistentRead = &file_options_proto_extTypes[3]

+ var E_RonyInternal = &file_options_proto_extTypes[4]

Feb 7, 2021

Changes in this version

+ var E_InconsistentRead = &file_options_proto_extTypes[3]

+ var E_RonyAggregate = &file_options_proto_extTypes[4]

+ var E_RonyAggregateCommand = &file_options_proto_extTypes[7]

+ var E_RonyAggregateEvent = &file_options_proto_extTypes[8]

+ var E_RonyAggregateLink = &file_options_proto_extTypes[9]

+ var E_RonyAggregateTable = &file_options_proto_extTypes[10]

+ var E_RonyAggregateType = &file_options_proto_extTypes[6]

+ var E_RonyAggregateView = &file_options_proto_extTypes[11]

Jan 29, 2021

Changes in this version

+ var E_RonyRepo = &file_options_proto_extTypes[0]

+ var E_RonySingleton = &file_options_proto_extTypes[7]

Jan 25, 2021

Changes in this version

+ var E_RonyIndex = &file_options_proto_extTypes[7]

Jan 13, 2021

Changes in this version

+ var E_RonyCobraCmdProtocol = &file_options_proto_extTypes[1]

Jan 12, 2021

Changes in this version

+ var E_RonyCobraCmd = &file_options_proto_extTypes[0]

Jan 12, 2021

Changes in this version

+ var E_Index = &file_options_proto_extTypes[5]

+ var E_PrimaryKey = &file_options_proto_extTypes[7]

+ var E_RonyModel = &file_options_proto_extTypes[2]

+ var E_RonyStorage = &file_options_proto_extTypes[0]

+ var E_RonyTable = &file_options_proto_extTypes[3]

+ var E_RonyView = &file_options_proto_extTypes[4]

+ var E_UniqueIndex = &file_options_proto_extTypes[6]

Jan 11, 2021

Changes in this version

type Error

+ func (x *Error) Error() string

Jan 10, 2021

Changes in this version

+ var E_Model = &file_options_proto_extTypes[1]

+ var E_Table = &file_options_proto_extTypes[2]

+ var E_View = &file_options_proto_extTypes[3]

Jan 9, 2021

Changes in this version

+ type Conn interface

+ ClientIP func() string

+ ConnID func() uint64

+ Get func(key string) interface{}

+ Persistent func() bool

+ SendBinary func(streamID int64, data []byte) error

+ Set func(key string, val interface{})

Jan 6, 2021

Changes in this version

+ const C_TunnelMessage

+ var PoolTunnelMessage = poolTunnelMessage

type EdgeNode

+ TunnelAddr []string

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

+ type TunnelMessage struct

+ Envelope *MessageEnvelope

+ SenderID []byte

+ SenderReplicaSet uint64

+ Store []*KeyValue

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

+ func (*TunnelMessage) ProtoMessage()

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

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

+ func (x *TunnelMessage) GetEnvelope() *MessageEnvelope

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

+ func (x *TunnelMessage) GetSenderReplicaSet() uint64

+ func (x *TunnelMessage) GetStore() []*KeyValue

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

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

+ func (x *TunnelMessage) Reset()

+ func (x *TunnelMessage) String() string

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

Jan 4, 2021

Changes in this version

+ const C_GetNodes

+ const C_NodeInfo

+ const C_NodeInfoMany

+ var E_FollowerOk = &file_options_proto_extTypes[0]

+ var ErrRaftAlreadyJoined = errors.New("raft already joined")

+ var File_options_proto protoreflect.FileDescriptor

+ var PoolGetNodes = poolGetNodes

+ var PoolNodeInfo = poolNodeInfo

+ var PoolNodeInfoMany = poolNodeInfoMany

+ var RedirectReason_name = map[int32]string

+ var RedirectReason_value = map[string]int32

+ type GetNodes struct

+ ReplicaSet []uint64

+ func (*GetNodes) Descriptor() ([]byte, []int)

+ func (*GetNodes) ProtoMessage()

+ func (x *GetNodes) DeepCopy(z *GetNodes)

+ func (x *GetNodes) GetReplicaSet() []uint64

+ func (x *GetNodes) Marshal() ([]byte, error)

+ func (x *GetNodes) ProtoReflect() protoreflect.Message

+ func (x *GetNodes) Reset()

+ func (x *GetNodes) String() string

+ func (x *GetNodes) Unmarshal(b []byte) error

+ type NodeInfo struct

+ HostPorts []string

+ Leader bool

+ ReplicaSet uint64

+ ServerID string

+ func (*NodeInfo) Descriptor() ([]byte, []int)

+ func (*NodeInfo) ProtoMessage()

+ func (x *NodeInfo) DeepCopy(z *NodeInfo)

+ func (x *NodeInfo) GetHostPorts() []string

+ func (x *NodeInfo) GetLeader() bool

+ func (x *NodeInfo) GetReplicaSet() uint64

+ func (x *NodeInfo) GetServerID() string

+ func (x *NodeInfo) Marshal() ([]byte, error)

+ func (x *NodeInfo) ProtoReflect() protoreflect.Message

+ func (x *NodeInfo) Reset()

+ func (x *NodeInfo) String() string

+ func (x *NodeInfo) Unmarshal(b []byte) error

+ type NodeInfoMany struct

+ Nodes []*NodeInfo

+ func (*NodeInfoMany) Descriptor() ([]byte, []int)

+ func (*NodeInfoMany) ProtoMessage()

+ func (x *NodeInfoMany) DeepCopy(z *NodeInfoMany)

+ func (x *NodeInfoMany) GetNodes() []*NodeInfo

+ func (x *NodeInfoMany) Marshal() ([]byte, error)

+ func (x *NodeInfoMany) ProtoReflect() protoreflect.Message

+ func (x *NodeInfoMany) Reset()

+ func (x *NodeInfoMany) String() string

+ func (x *NodeInfoMany) Unmarshal(b []byte) error

type Redirect

+ Followers []*NodeInfo

+ Leader *NodeInfo

+ Reason RedirectReason

+ func (x *Redirect) GetFollowers() []*NodeInfo

+ func (x *Redirect) GetLeader() *NodeInfo

+ func (x *Redirect) GetReason() RedirectReason

+ type RedirectReason int32

+ const RedirectReason_ReplicaMaster

+ const RedirectReason_ReplicaSetRequest

+ const RedirectReason_ReplicaSetSession

+ const RedirectReason_Reserved1

+ const RedirectReason_Reserved2

+ const RedirectReason_Reserved3

+ const RedirectReason_Reserved4

+ func (RedirectReason) Descriptor() protoreflect.EnumDescriptor

+ func (RedirectReason) EnumDescriptor() ([]byte, []int)

+ func (RedirectReason) Type() protoreflect.EnumType

+ func (x RedirectReason) Enum() *RedirectReason

+ func (x RedirectReason) Number() protoreflect.EnumNumber

+ func (x RedirectReason) String() string

Dec 11, 2020

Changes in this version

type MessageEnvelope

+ func (x *MessageEnvelope) Get(key, defaultVal string) string

+ func (x *MessageEnvelope) Set(KVs ...*KeyValue)

Dec 11, 2020

Changes in this version

type ClusterMessage

+ func (x *ClusterMessage) Marshal() ([]byte, error)

type EdgeNode

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

type Error

+ func (x *Error) Marshal() ([]byte, error)

type KeyValue

+ func (x *KeyValue) Marshal() ([]byte, error)

type MessageContainer

+ func (x *MessageContainer) Marshal() ([]byte, error)

type MessageEnvelope

+ func (x *MessageEnvelope) Marshal() ([]byte, error)

type RaftCommand

+ func (x *RaftCommand) Marshal() ([]byte, error)

type Redirect

+ func (x *Redirect) Marshal() ([]byte, error)

Dec 9, 2020

Changes in this version

+ const C_ClusterMessage

+ const C_EdgeNode

+ const C_Error

+ const C_KeyValue

+ const C_MessageContainer

+ const C_MessageEnvelope

+ const C_RaftCommand

+ const C_Redirect

+ const ErrCodeAccess

+ const ErrCodeAlreadyExists

+ const ErrCodeBusy

+ const ErrCodeExpired

+ const ErrCodeIncomplete

+ const ErrCodeInternal

+ const ErrCodeInvalid

+ const ErrCodeNotImplemented

+ const ErrCodeOutOfRange

+ const ErrCodePartiallyApplied

+ const ErrCodeTimeout

+ const ErrCodeTooFew

+ const ErrCodeTooMany

+ const ErrCodeUnavailable

+ const ErrItemHandler

+ const ErrItemRaftLeader

+ const ErrItemRequest

+ const ErrItemServer

+ var ConstructorNames = map[int64]string

+ var ErrGatewayAlreadyInitialized = errors.New("gateway already initialized")

+ var ErrNotFound = errors.New("not found")

+ var ErrNotRaftLeader = errors.New("not raft leader")

+ var ErrRaftExecuteOnLeader = errors.New("raft execute on leader")

+ var ErrRaftNotSet = errors.New("raft not set")

+ var ErrRetriesExceeded = wrapError("maximum retries exceeded")

+ var File_imsg_proto protoreflect.FileDescriptor

+ var File_msg_proto protoreflect.FileDescriptor

+ var PoolClusterMessage = poolClusterMessage

+ var PoolEdgeNode = poolEdgeNode

+ var PoolError = poolError

+ var PoolKeyValue = poolKeyValue

+ var PoolMessageContainer = poolMessageContainer

+ var PoolMessageEnvelope = poolMessageEnvelope

+ var PoolRaftCommand = poolRaftCommand

+ var PoolRedirect = poolRedirect

+ var RaftState_name = map[int32]string

+ var RaftState_value = map[string]int32

+ func ConstructorOf(x interface{}) int64

+ func ErrorMessage(out *MessageEnvelope, reqID uint64, errCode, errItem string)

+ func SetLogLevel(l int)

+ type ClusterMessage struct

+ Envelope *MessageEnvelope

+ Sender []byte

+ Store []*KeyValue

+ func (*ClusterMessage) Descriptor() ([]byte, []int)

+ func (*ClusterMessage) ProtoMessage()

+ func (x *ClusterMessage) DeepCopy(z *ClusterMessage)

+ func (x *ClusterMessage) Fill(senderID []byte, e *MessageEnvelope, kvs ...*KeyValue)

+ func (x *ClusterMessage) GetEnvelope() *MessageEnvelope

+ func (x *ClusterMessage) GetSender() []byte

+ func (x *ClusterMessage) GetStore() []*KeyValue

+ func (x *ClusterMessage) MarshalTo(b []byte) ([]byte, error)

+ func (x *ClusterMessage) ProtoReflect() protoreflect.Message

+ func (x *ClusterMessage) Reset()

+ func (x *ClusterMessage) String() string

+ func (x *ClusterMessage) Unmarshal(b []byte) error

+ type EdgeNode struct

+ GatewayAddr []string

+ RaftPort uint32

+ RaftState RaftState

+ ReplicaSet uint64

+ ServerID []byte

+ ShardRangeMax uint32

+ ShardRangeMin uint32

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

+ func (*EdgeNode) ProtoMessage()

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

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

+ func (x *EdgeNode) GetRaftPort() uint32

+ func (x *EdgeNode) GetRaftState() RaftState

+ func (x *EdgeNode) GetReplicaSet() uint64

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

+ func (x *EdgeNode) GetShardRangeMax() uint32

+ func (x *EdgeNode) GetShardRangeMin() uint32

+ func (x *EdgeNode) MarshalTo(b []byte) ([]byte, error)

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

+ func (x *EdgeNode) Reset()

+ func (x *EdgeNode) String() string

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

+ type Error struct

+ Code string

+ Items string

+ LocalTemplate string

+ LocalTemplateItems []string

+ Template string

+ TemplateItems []string

+ func (*Error) Descriptor() ([]byte, []int)

+ func (*Error) ProtoMessage()

+ func (x *Error) DeepCopy(z *Error)

+ func (x *Error) GetCode() string

+ func (x *Error) GetItems() string

+ func (x *Error) GetLocalTemplate() string

+ func (x *Error) GetLocalTemplateItems() []string

+ func (x *Error) GetTemplate() string

+ func (x *Error) GetTemplateItems() []string

+ func (x *Error) MarshalTo(b []byte) ([]byte, error)

+ func (x *Error) ProtoReflect() protoreflect.Message

+ func (x *Error) Reset()

+ func (x *Error) String() string

+ func (x *Error) Unmarshal(b []byte) error

+ type KeyValue struct

+ Key string

+ Value string

+ func (*KeyValue) Descriptor() ([]byte, []int)

+ func (*KeyValue) ProtoMessage()

+ func (x *KeyValue) DeepCopy(z *KeyValue)

+ func (x *KeyValue) GetKey() string

+ func (x *KeyValue) GetValue() string

+ func (x *KeyValue) MarshalTo(b []byte) ([]byte, error)

+ func (x *KeyValue) ProtoReflect() protoreflect.Message

+ func (x *KeyValue) Reset()

+ func (x *KeyValue) String() string

+ func (x *KeyValue) Unmarshal(b []byte) error

+ type MessageContainer struct

+ Envelopes []*MessageEnvelope

+ Length int32

+ func (*MessageContainer) Descriptor() ([]byte, []int)

+ func (*MessageContainer) ProtoMessage()

+ func (x *MessageContainer) DeepCopy(z *MessageContainer)

+ func (x *MessageContainer) GetEnvelopes() []*MessageEnvelope

+ func (x *MessageContainer) GetLength() int32

+ func (x *MessageContainer) MarshalTo(b []byte) ([]byte, error)

+ func (x *MessageContainer) ProtoReflect() protoreflect.Message

+ func (x *MessageContainer) Reset()

+ func (x *MessageContainer) String() string

+ func (x *MessageContainer) Unmarshal(b []byte) error

+ type MessageEnvelope struct

+ Auth []byte

+ Constructor int64

+ Header []*KeyValue

+ Message []byte

+ RequestID uint64

+ func (*MessageEnvelope) Descriptor() ([]byte, []int)

+ func (*MessageEnvelope) ProtoMessage()

+ func (x *MessageEnvelope) Clone() *MessageEnvelope

+ func (x *MessageEnvelope) DeepCopy(z *MessageEnvelope)

+ func (x *MessageEnvelope) Fill(reqID uint64, constructor int64, p proto.Message, kvs ...*KeyValue)

+ func (x *MessageEnvelope) GetAuth() []byte

+ func (x *MessageEnvelope) GetConstructor() int64

+ func (x *MessageEnvelope) GetHeader() []*KeyValue

+ func (x *MessageEnvelope) GetMessage() []byte

+ func (x *MessageEnvelope) GetRequestID() uint64

+ func (x *MessageEnvelope) MarshalTo(b []byte) ([]byte, error)

+ func (x *MessageEnvelope) ProtoReflect() protoreflect.Message

+ func (x *MessageEnvelope) Reset()

+ func (x *MessageEnvelope) String() string

+ func (x *MessageEnvelope) Unmarshal(b []byte) error

+ type RaftCommand struct

+ Envelope *MessageEnvelope

+ Sender []byte

+ Store []*KeyValue

+ func (*RaftCommand) Descriptor() ([]byte, []int)

+ func (*RaftCommand) ProtoMessage()

+ func (x *RaftCommand) DeepCopy(z *RaftCommand)

+ func (x *RaftCommand) Fill(senderID []byte, e *MessageEnvelope, kvs ...*KeyValue)

+ func (x *RaftCommand) GetEnvelope() *MessageEnvelope

+ func (x *RaftCommand) GetSender() []byte

+ func (x *RaftCommand) GetStore() []*KeyValue

+ func (x *RaftCommand) MarshalTo(b []byte) ([]byte, error)

+ func (x *RaftCommand) ProtoReflect() protoreflect.Message

+ func (x *RaftCommand) Reset()

+ func (x *RaftCommand) String() string

+ func (x *RaftCommand) Unmarshal(b []byte) error

+ type RaftState int32

+ const RaftState_Candidate

+ const RaftState_Follower

+ const RaftState_Leader

+ const RaftState_None

+ const RaftState_Shutdown

+ func (RaftState) Descriptor() protoreflect.EnumDescriptor

+ func (RaftState) EnumDescriptor() ([]byte, []int)

+ func (RaftState) Type() protoreflect.EnumType

+ func (x RaftState) Enum() *RaftState

+ func (x RaftState) Number() protoreflect.EnumNumber

+ func (x RaftState) String() string

+ type Redirect struct

+ HostPorts []string

+ LeaderHostPort []string

+ ServerID string

+ WaitInSec uint32

+ func (*Redirect) Descriptor() ([]byte, []int)

+ func (*Redirect) ProtoMessage()

+ func (x *Redirect) DeepCopy(z *Redirect)

+ func (x *Redirect) GetHostPorts() []string

+ func (x *Redirect) GetLeaderHostPort() []string

+ func (x *Redirect) GetServerID() string

+ func (x *Redirect) GetWaitInSec() uint32

+ func (x *Redirect) MarshalTo(b []byte) ([]byte, error)

+ func (x *Redirect) ProtoReflect() protoreflect.Message

+ func (x *Redirect) Reset()

+ func (x *Redirect) String() string

+ func (x *Redirect) Unmarshal(b []byte) error