fallback

Documentation

Index

• func ExtractEvents(b []byte, rawFile, skipMalformed bool) ([]map[string]interface{}, error)
• type FileStatus
• type Service
  • func NewService(logEventsPath string, destinationService *destinations.Service, ...) (*Service, error)
  • func NewTestService() *Service
  • func (s *Service) GetFileStatuses(destinationsFilter map[string]bool) []*FileStatus
  • func (s *Service) Replay(fileName, destinationID string, rawFile, skipMalformed bool) error

Functions

func ExtractEvents

func ExtractEvents(b []byte, rawFile, skipMalformed bool) ([]map[string]interface{}, error)

ExtractEvents parses input bytes as plain jsons or fallback jsons or fallback jsons with skipping malformed objects

Types

type FileStatus

type FileStatus struct {
	FileName      string                      `json:"file_name"`
	DestinationID string                      `json:"destination_id"`
	TablesStatus  map[string]*logfiles.Status `json:"tables_statuses"`
}

type Service

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

Service stores and processes fallback files

func NewService

func NewService(logEventsPath string, destinationService *destinations.Service, usersRecognition events.Recognition) (*Service, error)

NewService returns configured Service

func NewTestService

func NewTestService() *Service

NewTestService returns test instance - only for tests

func (*Service) GetFileStatuses

func (s *Service) GetFileStatuses(destinationsFilter map[string]bool) []*FileStatus

GetFileStatuses returns all fallback files with their statuses

func (*Service) Replay

func (s *Service) Replay(fileName, destinationID string, rawFile, skipMalformed bool) error

Replay processes fallback file (or plain file) and store it in the destination