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 NewSocketEventHandler(server etp.Server, store *store.Store) *socketEventHandler
- 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)
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 NewSocketEventHandler ¶
func SetBackendDeclaration ¶
func SetBackendDeclaration(conn etp.Conn, backend structure.BackendDeclaration)
func SyncApplyCommand ¶
Types ¶
This section is empty.
Source Files
Click to show internal directories.
Click to hide internal directories.