perio

Documentation

Index

• Constants
• type Event
• type EventType
  • func (t EventType) String() string
• type PERIOGroup
• type Server
  • func OpenServer(wg *sync.WaitGroup) (*Server, error)
  • func (s *Server) AddPeriodReportTimer(lSeid uint64, urrid uint32, period time.Duration)
  • func (s *Server) Close()
  • func (s *Server) DelPeriodReportTimer(lSeid uint64, urrid uint32)
  • func (s *Server) Handle(handler report.Handler, ...)
  • func (s *Server) Serve(wg *sync.WaitGroup)

Constants

const (
	EVENT_CHANNEL_LEN = 512
)

Types

type Event

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

type EventType

type EventType uint8

const (
	TYPE_PERIO_ADD EventType = iota + 1
	TYPE_PERIO_DEL
	TYPE_PERIO_TIMEOUT
	TYPE_SERVER_CLOSE
)

func (EventType) String

func (t EventType) String() string

type PERIOGroup

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

type Server

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

func OpenServer

func OpenServer(wg *sync.WaitGroup) (*Server, error)

func (*Server) AddPeriodReportTimer

func (s *Server) AddPeriodReportTimer(lSeid uint64, urrid uint32, period time.Duration)

func (*Server) Close

func (s *Server) Close()

func (*Server) DelPeriodReportTimer

func (s *Server) DelPeriodReportTimer(lSeid uint64, urrid uint32)

func (*Server) Handle

func (s *Server) Handle(
	handler report.Handler,
	queryURR func(map[uint64][]uint32) (map[uint64][]report.USAReport, error),
)

func (*Server) Serve

func (s *Server) Serve(wg *sync.WaitGroup)