Outgoing

Documentation

Index

• type RPCInterface
  • func NewRPCInterface(serverAddress string) *RPCInterface
  • func (rpcI *RPCInterface) Connect() error
  • func (rpcI RPCInterface) CreateDelayedEvent(event []byte, delay *time.Duration) (err error)
  • func (rpcI RPCInterface) CreateEvent(event []byte) (err error)
  • func (rpcI RPCInterface) Disconnect()
  • func (rpcI RPCInterface) MakeCall(command string, event []byte) (result *Module.Result, err error)
  • func (rpcI RPCInterface) SendMessage(message *LogServer.LogMessage) (err error)
  • func (rpcI RPCInterface) SendMessages(messages *[]*LogServer.LogMessage) (err error)

Types

type RPCInterface

type RPCInterface struct {
	Config *tls.Config
	// contains filtered or unexported fields
}

RPCInterface represents a outgoing RPC connection, with which a rpc.Client can be created

func NewRPCInterface

func NewRPCInterface(serverAddress string) *RPCInterface

NewRPCInterface constructs a new RPCInterface

func (*RPCInterface) Connect

func (rpcI *RPCInterface) Connect() error

Connect establishes a tcp connection and single byte for authentication and creates a rpc.Client

func (RPCInterface) CreateDelayedEvent

func (rpcI RPCInterface) CreateDelayedEvent(event []byte, delay *time.Duration) (err error)

CreateDelayedEvent encapsulates the RPC call to create a DelayedEvent on the server

func (RPCInterface) CreateEvent

func (rpcI RPCInterface) CreateEvent(event []byte) (err error)

CreateEvent encapsulates the RPC call to create a Event on the server

func (RPCInterface) Disconnect

func (rpcI RPCInterface) Disconnect()

Disconnect closes the tcp connection

func (RPCInterface) MakeCall

func (rpcI RPCInterface) MakeCall(command string, event []byte) (result *Module.Result, err error)

MakeCall executes a given Module on the other side

func (RPCInterface) SendMessage

func (rpcI RPCInterface) SendMessage(message *LogServer.LogMessage) (err error)

SendMessage sends a message to the logserver

func (RPCInterface) SendMessages

func (rpcI RPCInterface) SendMessages(messages *[]*LogServer.LogMessage) (err error)

SendMessages sends a multiple messages to the logserver