ipc

May 15, 2024

Changes in this version

type Actor

+ func (a *Actor) ReadTimedTimeoutMessage(duration time.Duration, onTimeoutMessage *Message) (*Message, error)

+ func (a *Actor) WriteMessage(msg *Message) error

type Client

+ func StartClientPool(config *ClientConfig) (*Client, error)

+ type ConnectionPool struct

+ Logger *logrus.Logger

+ ServerConfig *ServerConfig

+ Servers []*Server

+ func (sm *ConnectionPool) Close()

+ func (sm *ConnectionPool) MapExec(callback func(*Server), from string)

+ func (sm *ConnectionPool) Read(callback func(*Server, *Message, error))

+ func (sm *ConnectionPool) ReadTimed(duration time.Duration, callback func(*Server, *Message, error))

+ func (sm *ConnectionPool) ReadTimedFastest(duration time.Duration, callback func(*Server, *Message, error))

type Server

+ Connections *ConnectionPool

+ func StartServerPool(config *ServerConfig) (*Server, error)

May 15, 2024

Changes in this version

type ServerManager

+ func (sm *ServerManager) Close()

May 11, 2024

Changes in this version

+ const DEFAULT_WAIT

type Actor

+ func (a *Actor) String() string

May 8, 2024

Changes in this version

+ const CLIENT_CONNECT_MSGTYPE

+ const ENCRYPT_BY_DEFAULT

+ const SOCKET_NAME_BASE

+ const SOCKET_NAME_EXT

+ var TimeoutMessage = &Message

+ func Sleep()

type Actor

+ func (a *Actor) ReadTimed(duration time.Duration, onTimeoutMessage *Message) (*Message, error)

+ type ActorInterface interface

+ String func() string

type Client

+ ClientId int

+ func NewClient(name string, config *ClientConfig) (*Client, error)

+ func StartMultiClient(config *ClientConfig) (*Client, error)

+ func StartOnlyClient(config *ClientConfig) (*Client, error)

+ func (c *Client) ByteReader(a *Actor, buff []byte) bool

+ func (c *Client) String() string

type ClientConfig

+ MultiClient bool

+ Name string

type Server

+ ServerManager *ServerManager

+ func NewServer(name string, config *ServerConfig) (*Server, error)

+ func StartMultiServer(config *ServerConfig) (*Server, error)

+ func StartOnlyServer(config *ServerConfig) (*Server, error)

+ func (s *Server) ByteReader(a *Actor, buff []byte) bool

type ServerConfig

+ MultiClient bool

+ Name string

+ type ServerManager struct

+ Logger *logrus.Logger

+ ServerConfig *ServerConfig

+ Servers []*Server

+ func (sm *ServerManager) MapExec(callback func(*Server), from string)

+ func (sm *ServerManager) Read(callback func(*Server, *Message, error))

+ func (sm *ServerManager) ReadTimed(duration time.Duration, timeoutMessage *Message, ...)

May 5, 2024

Changes in this version

+ const DEFAULT_CLIENT_CONNECT_WAIT

+ const DEFAULT_LOG_LEVEL

+ const MAX_MSG_SIZE

+ const VERSION

+ func GetDefaultClientConnectWait() int

+ type Actor struct

+ func NewActor(ac *ActorConfig) Actor

+ func (a *Actor) Close()

+ func (a *Actor) Read() (*Message, error)

+ func (a *Actor) Status() string

+ func (a *Actor) StatusCode() Status

+ func (a *Actor) Write(msgType int, message []byte) error

+ type ActorConfig struct

+ ClientConfig *ClientConfig

+ IsServer bool

+ MaxMsgSize int

+ Name string

+ ServerConfig *ServerConfig

type ClientConfig

+ LogLevel string

type ServerConfig

+ LogLevel string

Apr 30, 2024

Changes in this version

+ type Client struct

+ Name string

+ func StartClient(ipcName string, config *ClientConfig) (*Client, error)

+ func (c *Client) Close()

+ func (c *Client) Read() (*Message, error)

+ func (c *Client) Status() string

+ func (c *Client) StatusCode() Status

+ func (c *Client) Write(msgType int, message []byte) error

+ type ClientConfig struct

+ Encryption bool

+ RetryTimer time.Duration

+ Timeout float64

+ type Message struct

+ Data []byte

+ Err error

+ MsgType int

+ Status string

+ type Server struct

+ func StartServer(ipcName string, config *ServerConfig) (*Server, error)

+ func (s *Server) Close()

+ func (s *Server) Read() (*Message, error)

+ func (s *Server) Status() string

+ func (s *Server) StatusCode() Status

+ func (s *Server) Write(msgType int, message []byte) error

+ type ServerConfig struct

+ Encryption bool

+ MaxMsgSize int

+ UnmaskPermissions bool

+ type Status int

+ const Closed

+ const Closing

+ const Connected

+ const Connecting

+ const Disconnected

+ const Error

+ const Listening

+ const NotConnected

+ const ReConnecting

+ const Timeout

+ func (status *Status) String() string