service

Documentation

Overview

Package service is a generated GoMock package.

Index

• type IRumEventFactory
• type IService
• type ISubscriptionService
• type Lookup
• type MockISubscriptionService
  • func NewMockISubscriptionService(ctrl *gomock.Controller) *MockISubscriptionService
  • func (m *MockISubscriptionService) EXPECT() *MockISubscriptionServiceMockRecorder
  • func (m *MockISubscriptionService) GetSubscription(subscriptionID, hostname string) (Lookup, error)
  • func (m *MockISubscriptionService) Load() error
• type MockISubscriptionServiceMockRecorder
  • func (mr *MockISubscriptionServiceMockRecorder) GetSubscription(subscriptionID, hostname interface{}) *gomock.Call
  • func (mr *MockISubscriptionServiceMockRecorder) Load() *gomock.Call
• type RumEventFactory
  • func NewRumEventFactory(userAgentParser *uaparser.Parser, geoIPService geoip.Service) *RumEventFactory
  • func (s *RumEventFactory) Create(event *types.Event) beacon.RumEvent
• type Service
  • func New(rumEventFactory IRumEventFactory, daoService dao.IDAO, ...) *Service
  • func (s *Service) DeleteHostname(hostname, username string) error
  • func (s *Service) RegisterHostname(hostname, username string) error
  • func (s *Service) Run()
  • func (s *Service) SaveAsync(event *types.Event)

Types

type IRumEventFactory

type IRumEventFactory interface {
	// Create rum event from http captured event
	Create(event *types.Event) beacon.RumEvent
}

IRumEventFactory rum event factory interface

type IService

type IService interface {
	// Run runs the service
	Run()
	// SaveAsync saves an event asynchronously
	SaveAsync(event *types.Event)
	// RegisterHostname generates new subscription
	RegisterHostname(hostname, username string) error
	// DeleteHostname deletes the hostname
	DeleteHostname(hostname, username string) error
}

IService service interface

type ISubscriptionService

type ISubscriptionService interface {
	// Load initial data
	Load() error
	// GetSubscription get subscription by id and hostname
	GetSubscription(subscriptionID, hostname string) (Lookup, error)
}

ISubscriptionService subscription service

type Lookup

type Lookup string

Lookup describes subscription lookup statuses

const (
	// FoundLookup found
	FoundLookup Lookup = "FOUND"
	// NotFoundLookup not found
	NotFoundLookup Lookup = "NOT_FOUND"
	// ExpiredLookup expired
	ExpiredLookup Lookup = "EXPIRED"
)

type MockISubscriptionService

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

MockISubscriptionService is a mock of ISubscriptionService interface.

func NewMockISubscriptionService

func NewMockISubscriptionService(ctrl *gomock.Controller) *MockISubscriptionService

NewMockISubscriptionService creates a new mock instance.

func (*MockISubscriptionService) EXPECT

func (m *MockISubscriptionService) EXPECT() *MockISubscriptionServiceMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

func (*MockISubscriptionService) GetSubscription

func (m *MockISubscriptionService) GetSubscription(subscriptionID, hostname string) (Lookup, error)

GetSubscription mocks base method.

func (*MockISubscriptionService) Load

func (m *MockISubscriptionService) Load() error

Load mocks base method.

type MockISubscriptionServiceMockRecorder

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

MockISubscriptionServiceMockRecorder is the mock recorder for MockISubscriptionService.

func (*MockISubscriptionServiceMockRecorder) GetSubscription

func (mr *MockISubscriptionServiceMockRecorder) GetSubscription(subscriptionID, hostname interface{}) *gomock.Call

GetSubscription indicates an expected call of GetSubscription.

func (*MockISubscriptionServiceMockRecorder) Load

func (mr *MockISubscriptionServiceMockRecorder) Load() *gomock.Call

Load indicates an expected call of Load.

type RumEventFactory

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

RumEventFactory creates rum event

func NewRumEventFactory

func NewRumEventFactory(
	userAgentParser *uaparser.Parser,
	geoIPService geoip.Service,
) *RumEventFactory

NewRumEventFactory creates rum event factory

func (*RumEventFactory) Create

func (s *RumEventFactory) Create(event *types.Event) beacon.RumEvent

Create rum event from http captured event

type Service

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

Service processes events and stores them in database access object

func New

func New(
	rumEventFactory IRumEventFactory,
	daoService dao.IDAO,
	backupService backup.IBackup,
) *Service

New creates processing service nolint: revive

func (*Service) DeleteHostname

func (s *Service) DeleteHostname(hostname, username string) error

DeleteHostname deletes the hostname

func (*Service) RegisterHostname

func (s *Service) RegisterHostname(hostname, username string) error

RegisterHostname generates new subscription

func (*Service) Run

func (s *Service) Run()

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

func (*Service) SaveAsync

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

SaveAsync saves an event asynchronously