transmitter

Documentation

Index

• type Service
  • func NewService(name string) *Service
  • func (service *Service) Close()
  • func (service *Service) Publish(event *models.Event, interval int) error
  • func (service *Service) RegisterRequestCallback(callback func(request *models.Request) bool)
  • func (service *Service) Start()

Types

type Service

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

Service implements the kvmtop communication service to transmit events to the message bus

func NewService

func NewService(name string) *Service

NewService instantiates a new communication service

func (*Service) Close

func (service *Service) Close()

Close terminates the transmitter service

func (*Service) Publish

func (service *Service) Publish(event *models.Event, interval int) error

Publish allows to transmit an event through the communication service

func (*Service) RegisterRequestCallback

func (service *Service) RegisterRequestCallback(callback func(request *models.Request) bool)

RegisterRequestCallback registers the callback used for handling requests

func (*Service) Start

func (service *Service) Start()

Start establishs the communication service