natsdaemon

Documentation

Index

• func NewIncomingMsgHandler(logger *logrus.Logger, incomingChan chan *api.ChatMessage) nats.MsgHandler
• type ChatConnection
  • func (c *ChatConnection) Close() (err error)
  • func (c *ChatConnection) Send(srv api.Daemon_SendServer) error
• type Session
  • func Online(logger *logrus.Logger, natsUrl string, senderAddress string) (*Session, error)
  • func (s *Session) Close() (err error)
  • func (s *Session) Dial(recepient string) (*ChatConnection, error)
• type ShutdownableDaemonServer
  • func NewDaemon(logger *logrus.Logger) ShutdownableDaemonServer

Functions

func NewIncomingMsgHandler

func NewIncomingMsgHandler(logger *logrus.Logger, incomingChan chan *api.ChatMessage) nats.MsgHandler

Types

type ChatConnection

type ChatConnection struct {
	SenderAddress    string
	RecepientAddress string
	// contains filtered or unexported fields
}

func (*ChatConnection) Close

func (c *ChatConnection) Close() (err error)

func (*ChatConnection) Send

func (c *ChatConnection) Send(srv api.Daemon_SendServer) error

type Session

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

func Online

func Online(logger *logrus.Logger, natsUrl string, senderAddress string) (*Session, error)

func (*Session) Close

func (s *Session) Close() (err error)

func (*Session) Dial

func (s *Session) Dial(recepient string) (*ChatConnection, error)

type ShutdownableDaemonServer

type ShutdownableDaemonServer interface {
	api.DaemonServer
	Shutdown() error
}

func NewDaemon

func NewDaemon(logger *logrus.Logger) ShutdownableDaemonServer