Documentation ¶
Index ¶
- Constants
- Variables
- func ConstructorOf(x interface{}) int64
- func CreatePage(m *Page) error
- func CreatePageWithTxn(txn *store.LTxn, alloc *tools.Allocator, m *Page) (err error)
- func DeletePage(id uint32) error
- func DeletePageWithTxn(txn *store.LTxn, alloc *tools.Allocator, id uint32) error
- func IterPageByReplicaSet(txn *store.LTxn, alloc *tools.Allocator, replicaSet uint64, ...) error
- func IterPages(txn *store.LTxn, alloc *tools.Allocator, cb func(m *Page) bool, ...) error
- func RegisterPrometheus(registerer prometheus.Registerer)
- func SavePage(m *Page) error
- func SavePageWithTxn(txn *store.LTxn, alloc *tools.Allocator, m *Page) (err error)
- func SetLogLevel(l int)
- func UpdatePage(id uint32, m *Page) error
- func UpdatePageWithTxn(txn *store.LTxn, alloc *tools.Allocator, m *Page) error
- type Conn
- type Edge
- func (x *Edge) DeepCopy(z *Edge)
- func (*Edge) Descriptor() ([]byte, []int)deprecated
- func (x *Edge) GetHostPorts() []string
- func (x *Edge) GetReplicaSet() uint64
- func (x *Edge) GetServerID() string
- func (x *Edge) Marshal() ([]byte, error)
- func (*Edge) ProtoMessage()
- func (x *Edge) ProtoReflect() protoreflect.Message
- func (x *Edge) Reset()
- func (x *Edge) String() string
- func (x *Edge) Unmarshal(b []byte) error
- type EdgeNode
- func (x *EdgeNode) DeepCopy(z *EdgeNode)
- func (*EdgeNode) Descriptor() ([]byte, []int)deprecated
- 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 (*EdgeNode) ProtoMessage()
- func (x *EdgeNode) ProtoReflect() protoreflect.Message
- func (x *EdgeNode) Reset()
- func (x *EdgeNode) String() string
- func (x *EdgeNode) Unmarshal(b []byte) error
- type Edges
- func (x *Edges) DeepCopy(z *Edges)
- func (*Edges) Descriptor() ([]byte, []int)deprecated
- func (x *Edges) GetNodes() []*Edge
- func (x *Edges) Marshal() ([]byte, error)
- func (*Edges) ProtoMessage()
- func (x *Edges) ProtoReflect() protoreflect.Message
- func (x *Edges) Reset()
- func (x *Edges) String() string
- func (x *Edges) Unmarshal(b []byte) error
- type Error
- func (x *Error) DeepCopy(z *Error)
- func (*Error) Descriptor() ([]byte, []int)deprecated
- func (x *Error) Error() string
- func (x *Error) Expand() (string, string)
- func (x *Error) GetCode() string
- func (x *Error) GetDescription() string
- func (x *Error) GetItems() string
- func (x *Error) Marshal() ([]byte, error)
- func (*Error) ProtoMessage()
- func (x *Error) ProtoReflect() protoreflect.Message
- func (x *Error) Reset()
- func (x *Error) String() string
- func (x *Error) ToEnvelope(me *MessageEnvelope)
- func (x *Error) Unmarshal(b []byte) error
- type GetAllNodes
- func (x *GetAllNodes) DeepCopy(z *GetAllNodes)
- func (*GetAllNodes) Descriptor() ([]byte, []int)deprecated
- func (x *GetAllNodes) Marshal() ([]byte, error)
- func (*GetAllNodes) ProtoMessage()
- func (x *GetAllNodes) ProtoReflect() protoreflect.Message
- func (x *GetAllNodes) Reset()
- func (x *GetAllNodes) String() string
- func (x *GetAllNodes) Unmarshal(b []byte) error
- type GetNodes
- func (x *GetNodes) DeepCopy(z *GetNodes)
- func (*GetNodes) Descriptor() ([]byte, []int)deprecated
- func (x *GetNodes) GetReplicaSet() []uint64
- func (x *GetNodes) Marshal() ([]byte, error)
- func (*GetNodes) ProtoMessage()
- func (x *GetNodes) ProtoReflect() protoreflect.Message
- func (x *GetNodes) Reset()
- func (x *GetNodes) String() string
- func (x *GetNodes) Unmarshal(b []byte) error
- type GetPage
- func (x *GetPage) DeepCopy(z *GetPage)
- func (*GetPage) Descriptor() ([]byte, []int)deprecated
- func (x *GetPage) GetPageID() uint32
- func (x *GetPage) GetReplicaSet() uint64
- func (x *GetPage) Marshal() ([]byte, error)
- func (*GetPage) ProtoMessage()
- func (x *GetPage) ProtoReflect() protoreflect.Message
- func (x *GetPage) Reset()
- func (x *GetPage) String() string
- func (x *GetPage) Unmarshal(b []byte) error
- type HttpBody
- func (x *HttpBody) DeepCopy(z *HttpBody)
- func (*HttpBody) Descriptor() ([]byte, []int)deprecated
- func (x *HttpBody) GetBody() []byte
- func (x *HttpBody) GetContentType() string
- func (x *HttpBody) GetHeader() []*KeyValue
- func (x *HttpBody) Marshal() ([]byte, error)
- func (*HttpBody) ProtoMessage()
- func (x *HttpBody) ProtoReflect() protoreflect.Message
- func (x *HttpBody) Reset()
- func (x *HttpBody) String() string
- func (x *HttpBody) Unmarshal(b []byte) error
- type KeyValue
- func (x *KeyValue) DeepCopy(z *KeyValue)
- func (*KeyValue) Descriptor() ([]byte, []int)deprecated
- func (x *KeyValue) GetKey() string
- func (x *KeyValue) GetValue() string
- func (x *KeyValue) Marshal() ([]byte, error)
- func (*KeyValue) ProtoMessage()
- func (x *KeyValue) ProtoReflect() protoreflect.Message
- func (x *KeyValue) Reset()
- func (x *KeyValue) String() string
- func (x *KeyValue) Unmarshal(b []byte) error
- type MessageContainer
- func (x *MessageContainer) Add(reqID uint64, constructor int64, p proto.Message, kvs ...*KeyValue)
- func (x *MessageContainer) DeepCopy(z *MessageContainer)
- func (*MessageContainer) Descriptor() ([]byte, []int)deprecated
- func (x *MessageContainer) GetEnvelopes() []*MessageEnvelope
- func (x *MessageContainer) GetLength() int32
- func (x *MessageContainer) Marshal() ([]byte, error)
- func (*MessageContainer) ProtoMessage()
- func (x *MessageContainer) ProtoReflect() protoreflect.Message
- func (x *MessageContainer) Reset()
- func (x *MessageContainer) String() string
- func (x *MessageContainer) Unmarshal(b []byte) error
- type MessageEnvelope
- func (x *MessageEnvelope) Clone() *MessageEnvelope
- func (x *MessageEnvelope) DeepCopy(z *MessageEnvelope)
- func (*MessageEnvelope) Descriptor() ([]byte, []int)deprecated
- func (x *MessageEnvelope) Fill(reqID uint64, constructor int64, p proto.Message, kvs ...*KeyValue)
- func (x *MessageEnvelope) Get(key, defaultVal string) string
- 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) Marshal() ([]byte, error)
- func (*MessageEnvelope) ProtoMessage()
- func (x *MessageEnvelope) ProtoReflect() protoreflect.Message
- func (x *MessageEnvelope) Reset()
- func (x *MessageEnvelope) Set(KVs ...*KeyValue)
- func (x *MessageEnvelope) String() string
- func (x *MessageEnvelope) Unmarshal(b []byte) error
- type Page
- 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 *store.LTxn, alloc *tools.Allocator, replicaSet uint64, id uint32, m *Page) (*Page, error)
- func ReadPageWithTxn(txn *store.LTxn, alloc *tools.Allocator, id uint32, m *Page) (*Page, error)
- func (x *Page) DeepCopy(z *Page)
- func (*Page) Descriptor() ([]byte, []int)deprecated
- func (x *Page) GetID() uint32
- func (x *Page) GetReplicaSet() uint64
- func (x *Page) Marshal() ([]byte, error)
- func (*Page) ProtoMessage()
- func (x *Page) ProtoReflect() protoreflect.Message
- func (x *Page) Reset()
- func (x *Page) String() string
- func (x *Page) Unmarshal(b []byte) error
- type PageOrder
- type Redirect
- func (x *Redirect) DeepCopy(z *Redirect)
- func (*Redirect) Descriptor() ([]byte, []int)deprecated
- func (x *Redirect) GetEdges() []*Edge
- func (x *Redirect) GetReason() RedirectReason
- func (x *Redirect) GetWaitInSec() uint32
- func (x *Redirect) Marshal() ([]byte, error)
- func (*Redirect) ProtoMessage()
- func (x *Redirect) ProtoReflect() protoreflect.Message
- func (x *Redirect) Reset()
- func (x *Redirect) String() string
- func (x *Redirect) Unmarshal(b []byte) error
- type RedirectReason
- func (RedirectReason) Descriptor() protoreflect.EnumDescriptor
- func (x RedirectReason) Enum() *RedirectReason
- func (RedirectReason) EnumDescriptor() ([]byte, []int)deprecated
- func (x RedirectReason) Number() protoreflect.EnumNumber
- func (x RedirectReason) String() string
- func (RedirectReason) Type() protoreflect.EnumType
- type TunnelMessage
- func (x *TunnelMessage) DeepCopy(z *TunnelMessage)
- func (*TunnelMessage) Descriptor() ([]byte, []int)deprecated
- 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 (*TunnelMessage) ProtoMessage()
- func (x *TunnelMessage) ProtoReflect() protoreflect.Message
- func (x *TunnelMessage) Reset()
- func (x *TunnelMessage) String() string
- func (x *TunnelMessage) Unmarshal(b []byte) error
Constants ¶
const C_Edge int64 = 3576986712
const C_EdgeNode int64 = 999040174
const C_Edges int64 = 2120950449
const C_Error int64 = 2619118453
const C_GetAllNodes int64 = 3267106379
const C_GetNodes int64 = 362407405
const C_GetPage int64 = 3721890413
const C_HttpBody int64 = 3032622721
const C_KeyValue int64 = 4276272820
const C_MessageContainer int64 = 1972016308
const C_MessageEnvelope int64 = 535232465
const C_Page int64 = 3023575326
const C_Redirect int64 = 981138557
const C_TunnelMessage int64 = 3271476222
Variables ¶
var ( RedirectReason_name = map[int32]string{ 0: "ReplicaSetSession", 1: "ReplicaSetRequest", 3: "Reserved1", 4: "Reserved2", 5: "Reserved3", 6: "Reserved4", } RedirectReason_value = map[string]int32{ "ReplicaSetSession": 0, "ReplicaSetRequest": 1, "Reserved1": 3, "Reserved2": 4, "Reserved3": 5, "Reserved4": 6, } )
Enum value maps for RedirectReason.
var ( // rony_cobra_cmd generates the boiler plate code for client stub of rpc methods, using cobra package. // // optional bool rony_cobra_cmd = 50001; E_RonyCobraCmd = &file_options_proto_extTypes[0] // rony_cobra_cmd_protocol defines what protocol should client use to communicate with server. // POSSIBLE VALUES: "ws", "http" // // optional string rony_cobra_cmd_protocol = 50002; E_RonyCobraCmdProtocol = &file_options_proto_extTypes[1] // rony_no_client if is set then no client code will be generated. This flag is for internal usage. // DO NOT USE IT. // // optional bool rony_no_client = 50003; E_RonyNoClient = &file_options_proto_extTypes[2] )
Extension fields to descriptorpb.ServiceOptions.
var ( // rony_aggregate marks this message as an aggregate, then 'rony_table' and 'rony_view' options become available for this // message. // // optional bool rony_aggregate = 50001; E_RonyAggregate = &file_options_proto_extTypes[4] // rony_singleton marks this message as a singleton. // NOTE: a message could either have 'rony_aggregate' ro 'rony_singleton' options at a same time. Setting both // cause unpredictable results. // // optional bool rony_singleton = 50002; E_RonySingleton = &file_options_proto_extTypes[5] // rony_aggregate_type makes the code generator to generate appropriate functions based on the way you are going // to handle actions on the aggregate. // POSSIBLE_VALUES: "crud", "eventsource" // // optional string rony_aggregate_type = 50010; E_RonyAggregateType = &file_options_proto_extTypes[6] // rony_aggregate_command makes this message as a command which is ONLY used if rony_aggregate_type is set to 'eventsource'. // If this option is set then you MUST also define rony_aggregate_link to identify which aggregate this command will work on. // // optional bool rony_aggregate_command = 50011; E_RonyAggregateCommand = &file_options_proto_extTypes[7] // rony_aggregate_event makes this message as an event which is ONLY used if rony_aggregate_type is set to 'eventsource' // If this option is set then you MUST also define rony_aggregate_link to identify which aggregate this event will be read from. // // optional bool rony_aggregate_event = 50012; E_RonyAggregateEvent = &file_options_proto_extTypes[8] // rony_aggregate_link is the name of the aggregate message which we link this message to. // // optional string rony_aggregate_link = 50013; E_RonyAggregateLink = &file_options_proto_extTypes[9] // rony_aggregate_table creates a virtual table presentation to hold instances of this message, like rows in a table // PRIMARY KEY FORMAT: ( (partitionKey1, partitionKey2, ...), clusteringKey1, clusteringKey2, ...) // NOTE: If there is only one partition key then you could safely drop the parenthesis, i.e. (pk1, ck1, ck2) // // optional string rony_aggregate_table = 50014; E_RonyAggregateTable = &file_options_proto_extTypes[10] // rony_aggregate_view creates a materialized view of the aggregate based on the primary key. // PRIMARY KEY FORMAT: ( (partitionKey1, partitionKey2, ...), clusteringKey1, clusteringKey2, ...) // NOTE (1): If there is only one partition key then you could safely drop the parenthesis, i.e. (pk1, ck1, ck2) // NOTE (2): The primary key of the model must contains all the primary key items of the table. They don't need to // follow the same order as table. for example the following is correct: // rony_aggregate_table = ((a, b), c) // rony_aggregate_view = ((c, a), d, b) // // repeated string rony_aggregate_view = 50015; E_RonyAggregateView = &file_options_proto_extTypes[11] )
Extension fields to descriptorpb.MessageOptions.
var (
// optional bool rony_index = 50001;
E_RonyIndex = &file_options_proto_extTypes[12]
)
Extension fields to descriptorpb.FieldOptions.
var ( // rony_internal marks this method internal, hence only edges could execute this rpc through tunnel messages. In other words, // this command is not exposed to external clients connected through th gateway. // // optional bool rony_internal = 50002; E_RonyInternal = &file_options_proto_extTypes[3] )
Extension fields to descriptorpb.MethodOptions.
var File_imsg_proto protoreflect.FileDescriptor
var File_msg_proto protoreflect.FileDescriptor
var File_options_proto protoreflect.FileDescriptor
var PoolEdge = poolEdge{}
var PoolEdgeNode = poolEdgeNode{}
var PoolEdges = poolEdges{}
var PoolError = poolError{}
var PoolGetAllNodes = poolGetAllNodes{}
var PoolGetNodes = poolGetNodes{}
var PoolGetPage = poolGetPage{}
var PoolHttpBody = poolHttpBody{}
var PoolKeyValue = poolKeyValue{}
var PoolMessageContainer = poolMessageContainer{}
var PoolMessageEnvelope = poolMessageEnvelope{}
var PoolPage = poolPage{}
var PoolRedirect = poolRedirect{}
var PoolTunnelMessage = poolTunnelMessage{}
Functions ¶
func ConstructorOf ¶
func ConstructorOf(x interface{}) int64
func CreatePage ¶ added in v0.5.25
func CreatePageWithTxn ¶ added in v0.5.25
func DeletePage ¶ added in v0.5.0
func DeletePageWithTxn ¶ added in v0.5.0
func IterPageByReplicaSet ¶ added in v0.5.0
func RegisterPrometheus ¶ added in v0.5.8
func RegisterPrometheus(registerer prometheus.Registerer)
func SavePageWithTxn ¶ added in v0.5.0
func SetLogLevel ¶
func SetLogLevel(l int)
SetLogLevel is used for debugging purpose -1 : DEBUG 0 : INFO 1 : WARN 2 : ERROR
func UpdatePage ¶ added in v0.5.25
Types ¶
type Conn ¶ added in v0.1.9
type Conn interface { ConnID() uint64 ClientIP() string SendBinary(streamID int64, data []byte) error // Persistent returns FALSE if this connection will be closed when edge.DispatchCtx has been done. i.e. HTTP connections // It returns TRUE if this connection still alive when edge.DispatchCtx has been done. i.e. WebSocket connections Persistent() bool Get(key string) interface{} Set(key string, val interface{}) }
Conn defines the Connection interface
type Edge ¶ added in v0.5.0
type Edge struct { ReplicaSet uint64 `protobuf:"varint,1,opt,name=ReplicaSet,proto3" json:"ReplicaSet,omitempty"` ServerID string `protobuf:"bytes,2,opt,name=ServerID,proto3" json:"ServerID,omitempty"` HostPorts []string `protobuf:"bytes,3,rep,name=HostPorts,proto3" json:"HostPorts,omitempty"` // contains filtered or unexported fields }
Edge
func (*Edge) Descriptor
deprecated
added in
v0.5.0
func (*Edge) GetHostPorts ¶ added in v0.5.0
func (*Edge) GetReplicaSet ¶ added in v0.5.0
func (*Edge) GetServerID ¶ added in v0.5.0
func (*Edge) ProtoMessage ¶ added in v0.5.0
func (*Edge) ProtoMessage()
func (*Edge) ProtoReflect ¶ added in v0.5.0
func (x *Edge) ProtoReflect() protoreflect.Message
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) Descriptor
deprecated
func (*EdgeNode) GetGatewayAddr ¶
func (*EdgeNode) GetReplicaSet ¶
func (*EdgeNode) GetServerID ¶
func (*EdgeNode) GetTunnelAddr ¶ added in v0.1.8
func (*EdgeNode) ProtoMessage ¶
func (*EdgeNode) ProtoMessage()
func (*EdgeNode) ProtoReflect ¶
func (x *EdgeNode) ProtoReflect() protoreflect.Message
type Edges ¶ added in v0.5.0
type Edges struct { Nodes []*Edge `protobuf:"bytes,1,rep,name=Nodes,proto3" json:"Nodes,omitempty"` // contains filtered or unexported fields }
Edges
func (*Edges) Descriptor
deprecated
added in
v0.5.0
func (*Edges) ProtoMessage ¶ added in v0.5.0
func (*Edges) ProtoMessage()
func (*Edges) ProtoReflect ¶ added in v0.5.0
func (x *Edges) ProtoReflect() protoreflect.Message
type Error ¶
type Error struct { Code string `protobuf:"bytes,1,opt,name=Code,proto3" json:"Code,omitempty"` Items string `protobuf:"bytes,2,opt,name=Items,proto3" json:"Items,omitempty"` Description string `protobuf:"bytes,3,opt,name=Description,proto3" json:"Description,omitempty"` // contains filtered or unexported fields }
Error
func (*Error) Descriptor
deprecated
func (*Error) GetDescription ¶ added in v0.5.0
func (*Error) ProtoMessage ¶
func (*Error) ProtoMessage()
func (*Error) ProtoReflect ¶
func (x *Error) ProtoReflect() protoreflect.Message
func (*Error) ToEnvelope ¶ added in v0.8.0
func (x *Error) ToEnvelope(me *MessageEnvelope)
type GetAllNodes ¶ added in v0.7.4
type GetAllNodes struct {
// contains filtered or unexported fields
}
GetNodes @Function @Return: Edges
func (*GetAllNodes) DeepCopy ¶ added in v0.7.4
func (x *GetAllNodes) DeepCopy(z *GetAllNodes)
func (*GetAllNodes) Descriptor
deprecated
added in
v0.7.4
func (*GetAllNodes) Descriptor() ([]byte, []int)
Deprecated: Use GetAllNodes.ProtoReflect.Descriptor instead.
func (*GetAllNodes) Marshal ¶ added in v0.7.4
func (x *GetAllNodes) Marshal() ([]byte, error)
func (*GetAllNodes) ProtoMessage ¶ added in v0.7.4
func (*GetAllNodes) ProtoMessage()
func (*GetAllNodes) ProtoReflect ¶ added in v0.7.4
func (x *GetAllNodes) ProtoReflect() protoreflect.Message
func (*GetAllNodes) Reset ¶ added in v0.7.4
func (x *GetAllNodes) Reset()
func (*GetAllNodes) String ¶ added in v0.7.4
func (x *GetAllNodes) String() string
func (*GetAllNodes) Unmarshal ¶ added in v0.7.4
func (x *GetAllNodes) Unmarshal(b []byte) error
type GetNodes ¶ added in v0.1.5
type GetNodes struct { ReplicaSet []uint64 `protobuf:"varint,1,rep,packed,name=ReplicaSet,proto3" json:"ReplicaSet,omitempty"` // contains filtered or unexported fields }
GetNodes @Function @Return: Edges
func (*GetNodes) Descriptor
deprecated
added in
v0.1.5
func (*GetNodes) GetReplicaSet ¶ added in v0.1.5
func (*GetNodes) ProtoMessage ¶ added in v0.1.5
func (*GetNodes) ProtoMessage()
func (*GetNodes) ProtoReflect ¶ added in v0.1.5
func (x *GetNodes) ProtoReflect() protoreflect.Message
type GetPage ¶ added in v0.5.0
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) Descriptor
deprecated
added in
v0.5.0
func (*GetPage) GetReplicaSet ¶ added in v0.5.0
func (*GetPage) ProtoMessage ¶ added in v0.5.0
func (*GetPage) ProtoMessage()
func (*GetPage) ProtoReflect ¶ added in v0.5.0
func (x *GetPage) ProtoReflect() protoreflect.Message
type HttpBody ¶ added in v0.8.0
type HttpBody struct { ContentType string `protobuf:"bytes,1,opt,name=ContentType,proto3" json:"ContentType,omitempty"` Header []*KeyValue `protobuf:"bytes,2,rep,name=Header,proto3" json:"Header,omitempty"` Body []byte `protobuf:"bytes,3,opt,name=Body,proto3" json:"Body,omitempty"` // contains filtered or unexported fields }
HttpBody used by REST proxies to fill the output.
func (*HttpBody) Descriptor
deprecated
added in
v0.8.0
func (*HttpBody) GetContentType ¶ added in v0.8.0
func (*HttpBody) ProtoMessage ¶ added in v0.8.0
func (*HttpBody) ProtoMessage()
func (*HttpBody) ProtoReflect ¶ added in v0.8.0
func (x *HttpBody) ProtoReflect() protoreflect.Message
type KeyValue ¶
type KeyValue struct { Key string `protobuf:"bytes,1,opt,name=Key,proto3" json:"Key,omitempty"` Value string `protobuf:"bytes,2,opt,name=Value,proto3" json:"Value,omitempty"` // contains filtered or unexported fields }
KeyValue
func (*KeyValue) Descriptor
deprecated
func (*KeyValue) ProtoMessage ¶
func (*KeyValue) ProtoMessage()
func (*KeyValue) ProtoReflect ¶
func (x *KeyValue) ProtoReflect() protoreflect.Message
type MessageContainer ¶
type MessageContainer struct { Length int32 `protobuf:"varint,1,opt,name=Length,proto3" json:"Length,omitempty"` Envelopes []*MessageEnvelope `protobuf:"bytes,2,rep,name=Envelopes,proto3" json:"Envelopes,omitempty"` // contains filtered or unexported fields }
MessageContainer This type of message will be used to send multi messages inside a single container message
func (*MessageContainer) DeepCopy ¶
func (x *MessageContainer) DeepCopy(z *MessageContainer)
func (*MessageContainer) Descriptor
deprecated
func (*MessageContainer) Descriptor() ([]byte, []int)
Deprecated: Use MessageContainer.ProtoReflect.Descriptor instead.
func (*MessageContainer) GetEnvelopes ¶
func (x *MessageContainer) GetEnvelopes() []*MessageEnvelope
func (*MessageContainer) GetLength ¶
func (x *MessageContainer) GetLength() int32
func (*MessageContainer) Marshal ¶ added in v0.0.17
func (x *MessageContainer) Marshal() ([]byte, error)
func (*MessageContainer) ProtoMessage ¶
func (*MessageContainer) ProtoMessage()
func (*MessageContainer) ProtoReflect ¶
func (x *MessageContainer) ProtoReflect() protoreflect.Message
func (*MessageContainer) Reset ¶
func (x *MessageContainer) Reset()
func (*MessageContainer) String ¶
func (x *MessageContainer) String() string
func (*MessageContainer) Unmarshal ¶
func (x *MessageContainer) Unmarshal(b []byte) error
type MessageEnvelope ¶
type MessageEnvelope struct { Constructor int64 `protobuf:"varint,1,opt,name=Constructor,proto3" json:"Constructor,omitempty"` RequestID uint64 `protobuf:"fixed64,2,opt,name=RequestID,proto3" json:"RequestID,omitempty"` Message []byte `protobuf:"bytes,4,opt,name=Message,proto3" json:"Message,omitempty"` Auth []byte `protobuf:"bytes,8,opt,name=Auth,proto3" json:"Auth,omitempty"` Header []*KeyValue `protobuf:"bytes,10,rep,name=Header,proto3" json:"Header,omitempty"` // contains filtered or unexported fields }
MessageEnvelope This type of message will be used to contain another ProtoBuffer Message inside
func (*MessageEnvelope) Clone ¶
func (x *MessageEnvelope) Clone() *MessageEnvelope
func (*MessageEnvelope) DeepCopy ¶
func (x *MessageEnvelope) DeepCopy(z *MessageEnvelope)
func (*MessageEnvelope) Descriptor
deprecated
func (*MessageEnvelope) Descriptor() ([]byte, []int)
Deprecated: Use MessageEnvelope.ProtoReflect.Descriptor instead.
func (*MessageEnvelope) Get ¶ added in v0.0.18
func (x *MessageEnvelope) Get(key, defaultVal string) string
func (*MessageEnvelope) GetAuth ¶
func (x *MessageEnvelope) GetAuth() []byte
func (*MessageEnvelope) GetConstructor ¶
func (x *MessageEnvelope) GetConstructor() int64
func (*MessageEnvelope) GetHeader ¶
func (x *MessageEnvelope) GetHeader() []*KeyValue
func (*MessageEnvelope) GetMessage ¶
func (x *MessageEnvelope) GetMessage() []byte
func (*MessageEnvelope) GetRequestID ¶
func (x *MessageEnvelope) GetRequestID() uint64
func (*MessageEnvelope) Marshal ¶ added in v0.0.17
func (x *MessageEnvelope) Marshal() ([]byte, error)
func (*MessageEnvelope) ProtoMessage ¶
func (*MessageEnvelope) ProtoMessage()
func (*MessageEnvelope) ProtoReflect ¶
func (x *MessageEnvelope) ProtoReflect() protoreflect.Message
func (*MessageEnvelope) Reset ¶
func (x *MessageEnvelope) Reset()
func (*MessageEnvelope) Set ¶ added in v0.0.18
func (x *MessageEnvelope) Set(KVs ...*KeyValue)
func (*MessageEnvelope) String ¶
func (x *MessageEnvelope) String() string
func (*MessageEnvelope) Unmarshal ¶
func (x *MessageEnvelope) Unmarshal(b []byte) error
type Page ¶ added in v0.5.0
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 ListPageByReplicaSet ¶ added in v0.5.0
func ReadPageByReplicaSetAndID ¶ added in v0.5.0
func ReadPageByReplicaSetAndIDWithTxn ¶ added in v0.5.0
func ReadPageWithTxn ¶ added in v0.5.0
func (*Page) Descriptor
deprecated
added in
v0.5.0
func (*Page) GetReplicaSet ¶ added in v0.5.0
func (*Page) ProtoMessage ¶ added in v0.5.0
func (*Page) ProtoMessage()
func (*Page) ProtoReflect ¶ added in v0.5.0
func (x *Page) ProtoReflect() protoreflect.Message
type PageOrder ¶ added in v0.8.3
type PageOrder string
const PageOrderByReplicaSet PageOrder = "ReplicaSet"
type Redirect ¶
type Redirect struct { Reason RedirectReason `protobuf:"varint,100,opt,name=Reason,proto3,enum=rony.RedirectReason" json:"Reason,omitempty"` Edges []*Edge `protobuf:"bytes,2,rep,name=Edges,proto3" json:"Edges,omitempty"` WaitInSec uint32 `protobuf:"varint,3,opt,name=WaitInSec,proto3" json:"WaitInSec,omitempty"` // contains filtered or unexported fields }
Redirect
func (*Redirect) Descriptor
deprecated
func (*Redirect) GetReason ¶ added in v0.1.5
func (x *Redirect) GetReason() RedirectReason
func (*Redirect) GetWaitInSec ¶
func (*Redirect) ProtoMessage ¶
func (*Redirect) ProtoMessage()
func (*Redirect) ProtoReflect ¶
func (x *Redirect) ProtoReflect() protoreflect.Message
type RedirectReason ¶ added in v0.1.5
type RedirectReason int32
RedirectReason
const ( RedirectReason_ReplicaSetSession RedirectReason = 0 RedirectReason_ReplicaSetRequest RedirectReason = 1 RedirectReason_Reserved1 RedirectReason = 3 RedirectReason_Reserved2 RedirectReason = 4 RedirectReason_Reserved3 RedirectReason = 5 RedirectReason_Reserved4 RedirectReason = 6 )
func (RedirectReason) Descriptor ¶ added in v0.1.5
func (RedirectReason) Descriptor() protoreflect.EnumDescriptor
func (RedirectReason) Enum ¶ added in v0.1.5
func (x RedirectReason) Enum() *RedirectReason
func (RedirectReason) EnumDescriptor
deprecated
added in
v0.1.5
func (RedirectReason) EnumDescriptor() ([]byte, []int)
Deprecated: Use RedirectReason.Descriptor instead.
func (RedirectReason) Number ¶ added in v0.1.5
func (x RedirectReason) Number() protoreflect.EnumNumber
func (RedirectReason) String ¶ added in v0.1.5
func (x RedirectReason) String() string
func (RedirectReason) Type ¶ added in v0.1.5
func (RedirectReason) Type() protoreflect.EnumType
type TunnelMessage ¶ added in v0.1.8
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 []*KeyValue `protobuf:"bytes,3,rep,name=Store,proto3" json:"Store,omitempty"` Envelope *MessageEnvelope `protobuf:"bytes,4,opt,name=Envelope,proto3" json:"Envelope,omitempty"` // contains filtered or unexported fields }
TunnelMessage
func (*TunnelMessage) DeepCopy ¶ added in v0.1.8
func (x *TunnelMessage) DeepCopy(z *TunnelMessage)
func (*TunnelMessage) Descriptor
deprecated
added in
v0.1.8
func (*TunnelMessage) Descriptor() ([]byte, []int)
Deprecated: Use TunnelMessage.ProtoReflect.Descriptor instead.
func (*TunnelMessage) Fill ¶ added in v0.1.8
func (x *TunnelMessage) Fill(senderID []byte, senderReplicaSet uint64, e *MessageEnvelope, kvs ...*KeyValue)
func (*TunnelMessage) GetEnvelope ¶ added in v0.1.8
func (x *TunnelMessage) GetEnvelope() *MessageEnvelope
func (*TunnelMessage) GetSenderID ¶ added in v0.1.8
func (x *TunnelMessage) GetSenderID() []byte
func (*TunnelMessage) GetSenderReplicaSet ¶ added in v0.1.8
func (x *TunnelMessage) GetSenderReplicaSet() uint64
func (*TunnelMessage) GetStore ¶ added in v0.1.8
func (x *TunnelMessage) GetStore() []*KeyValue
func (*TunnelMessage) Marshal ¶ added in v0.1.8
func (x *TunnelMessage) Marshal() ([]byte, error)
func (*TunnelMessage) ProtoMessage ¶ added in v0.1.8
func (*TunnelMessage) ProtoMessage()
func (*TunnelMessage) ProtoReflect ¶ added in v0.1.8
func (x *TunnelMessage) ProtoReflect() protoreflect.Message
func (*TunnelMessage) Reset ¶ added in v0.1.8
func (x *TunnelMessage) Reset()
func (*TunnelMessage) String ¶ added in v0.1.8
func (x *TunnelMessage) String() string
func (*TunnelMessage) Unmarshal ¶ added in v0.1.8
func (x *TunnelMessage) Unmarshal(b []byte) error
Source Files ¶
Directories ¶
Path | Synopsis |
---|---|
cmd
|
|
internal
|
|
gateway/tcp/util
Package wsutil provides utilities for working with WebSocket protocol.
|
Package wsutil provides utilities for working with WebSocket protocol. |
parser
Package parse builds parse trees for templates as defined by text/template and html/template.
|
Package parse builds parse trees for templates as defined by text/template and html/template. |