iomanager

Documentation

Index

• type Config
• type IOManager
  • func New(c Config) (m IOManager, err error)
  • func (m IOManager) Start()
  • func (m IOManager) Stop() error

Types

type Config

type Config struct {
	NATSConn  *nats.Conn
	RedisConn *rediskv.Connection
}

Config describes the IO manager configuration.

type IOManager

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

IOManager contains the state of the IO Manager.

func New

func New(c Config) (m IOManager, err error)

New returns a new IO Manager.

func (IOManager) Start

func (m IOManager) Start()

Start starts the IO Manager by initializing handlers for NATS subscriptions.

func (IOManager) Stop

func (m IOManager) Stop() error

Stop stops the IO Manager by putting NATS subscriptions in a draining state.