service

package

v0.0.2 Latest Latest Go to latest Published: Sep 14, 2023 License: MIT Imports: 7 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

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

Service processes events and stores them in database access object

func New(
	daoService *dao.DAO,
	userAgentParser *uaparser.Parser,
	geoIPService geoip.Service,
) *Service

New creates processing service

func (s *Service) Run()

Run process the events from the channel and save them in datastore (click house)

func (s *Service) SaveAsync(event *types.Event)

SaveAsync saves an event asynchronously