bill

Documentation

Index

• Variables
• type Config
  • func NewConfig() *Config
• type Monitor
  • func NewMonitor(conf *Config, logger *util.Logger, db *reform.DB, pr *proc.Processor, ...) *Monitor
  • func (m *Monitor) Close()
  • func (m *Monitor) Run() error

Variables

var (
	ErrAlreadyRunning = errors.New("already running")
	ErrMonitorClosed  = errors.New("monitor closed")
)

Errors.

Types

type Config

type Config struct {
	CollectPeriod  uint // In milliseconds.
	RequestTLS     bool
	RequestTimeout uint // In milliseconds, must be less than CollectPeriod.
}

Config is a billing monitor configuration.

func NewConfig

func NewConfig() *Config

NewConfig creates a new billing monitor configuration.

type Monitor

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

Monitor is a client billing monitor.

func NewMonitor

func NewMonitor(conf *Config, logger *util.Logger, db *reform.DB,
	pr *proc.Processor, pscAddr string, pw data.PWDGetter) *Monitor

NewMonitor creates a new client billing monitor.

func (*Monitor) Close

func (m *Monitor) Close()

Close causes currently running Run() function to exit.

func (*Monitor) Run

func (m *Monitor) Run() error

Run processes billing for active client channels. This function does not return until an error occurs or Close() is called.