Incoming

package
v0.0.0-...-a93fc24 Latest Latest
Warning

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

Go to latest
Published: May 24, 2017 License: GPL-2.0 Imports: 14 Imported by: 2

Documentation

Index

Constants

This section is empty.

Variables

View Source
var ErrorInputWasNil = errors.New("The given input was a nil pointer")

ErrorInputWasNil will be returned if the RPC caller sends a nil object as input

View Source
var ErrorResultWasNil = errors.New("The given result was a nil pointer")

ErrorResultWasNil will be returned if the RPC caller sends a nil object as result

Functions

This section is empty.

Types

type LogServerRPCHandler

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

LogServerRPCHandler is a RPC handler which accepts LogMessages

func (*LogServerRPCHandler) SendMessage

func (handler *LogServerRPCHandler) SendMessage(message *LogServer.LogMessage, result *RPC.Result) error

SendMessage takes a single LogMessage

func (*LogServerRPCHandler) SendMessages

func (handler *LogServerRPCHandler) SendMessages(messages *[]*LogServer.LogMessage, result *RPC.Result) error

SendMessages takes a list of LogMessages

type LogServerRPCInterface

type LogServerRPCInterface struct {
	*RPCInterface
	// contains filtered or unexported fields
}

LogServerRPCInterface is RPC interface which offers logging

func NewLogServerRPCInterface

func NewLogServerRPCInterface(logQueue chan LogServer.LogMessage) *LogServerRPCInterface

NewLogServerRPCInterface creates a new LogServerRPCInterface

type ProxyRPCHandler

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

ProxyRPCHandler is a RPC handler which accepts LogMessages

func (*ProxyRPCHandler) Call

func (handler *ProxyRPCHandler) Call(call *RPC.Call, result *Module.Result) error

Call executes the given script and returns the result

type ProxyRPCInterface

type ProxyRPCInterface struct {
	*RPCInterface
}

ProxyRPCInterface is RPC interface which offers module execution

func NewProxyRPCInterface

func NewProxyRPCInterface() *ProxyRPCInterface

NewProxyRPCInterface creates a new ProxyRPCInterface

type RPCInterface

type RPCInterface struct {
	RPCListenTo string
	// contains filtered or unexported fields
}

RPCInterface represents a incoming RPC interface

func NewRPCInterface

func NewRPCInterface(listenTo string) *RPCInterface

NewRPCInterface creates a new RPCInterface

func (RPCInterface) IsRunning

func (rpcI RPCInterface) IsRunning() bool

IsRunning returns true if the daemon is running

func (*RPCInterface) Start

func (rpcI *RPCInterface) Start()

Start starts listening for requests

func (RPCInterface) Stop

func (rpcI RPCInterface) Stop()

Stop closes the port

type RuleSystemRPCHandler

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

RuleSystemRPCHandler RPC handler to create Events

func (*RuleSystemRPCHandler) CreateEvent

func (handler *RuleSystemRPCHandler) CreateEvent(rpcEvent *RPC.Event, result *RPC.Result) error

CreateEvent creates a event from the given string and sends it to the RuleSystem

type RuleSystemRPCInterface

type RuleSystemRPCInterface struct {
	*RPCInterface
	// contains filtered or unexported fields
}

RuleSystemRPCInterface offers a RPC interface to creates Events

func NewRuleSystemRPCInterface

func NewRuleSystemRPCInterface(ruleSystem *RuleSystem.RuleSystem) *RuleSystemRPCInterface

NewRuleSystemRPCInterface creates a new RuleSystemRPCInterface

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL