Documentation
¶
Index ¶
- func EmitConn(conn etp.Conn, event string, body []byte)
- func ExtractBackendDeclaration(conn etp.Conn) (structure.BackendDeclaration, bool)
- func FormatErrorConnection(err error) []byte
- func IsConfigClusterNode(conn etp.Conn) bool
- func Parameters(conn etp.Conn) (moduleName string, err error)
- func SetBackendDeclaration(conn etp.Conn, backend structure.BackendDeclaration)
- func SyncApplyCommand(command []byte, commandName string) (interface{}, error)
- type SocketEventHandler
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func ExtractBackendDeclaration ¶
func ExtractBackendDeclaration(conn etp.Conn) (structure.BackendDeclaration, bool)
func FormatErrorConnection ¶
func IsConfigClusterNode ¶
func SetBackendDeclaration ¶
func SetBackendDeclaration(conn etp.Conn, backend structure.BackendDeclaration)
func SyncApplyCommand ¶
Types ¶
type SocketEventHandler ¶
type SocketEventHandler struct {
// contains filtered or unexported fields
}
func NewSocketEventHandler ¶
func NewSocketEventHandler(server etp.Server, store *store.Store) *SocketEventHandler
func (*SocketEventHandler) SubscribeAll ¶
func (h *SocketEventHandler) SubscribeAll()
Source Files
Click to show internal directories.
Click to hide internal directories.