app

Documentation

Index

• type IndexedRedirects
  • func NewIndexedRedirects() *IndexedRedirects
  • func (idx *IndexedRedirects) Delete(pattern, fromDomain string)
  • func (idx *IndexedRedirects) IndexRule(pattern, fromDomain, target string)
  • func (idx *IndexedRedirects) Match(url string) (string, bool)
  • func (idx *IndexedRedirects) Update(pattern, fromDomain, target string)
• type Logger
  • func NewLogger(fileName string, gqlClient *v1.GraphQLClient) *Logger
  • func (l *Logger) LoadLoggedRequests() error
  • func (l *Logger) LogRequest(requestURL string) error
  • func (l *Logger) SendLogs()
  • func (l *Logger) SendLogsWeekly()
• type RedirectManager
  • func NewRedirectManager(db *sql.DB, gqlClient *api.GraphQLClient) *RedirectManager
  • func (rm *RedirectManager) DeleteOldRedirect(id string) error
  • func (rm *RedirectManager) FetchRedirectsOverChannel(redirectsCh chan<- []api.Redirect, errCh chan<- error)
  • func (rm *RedirectManager) HandleNewOrUpdatedRedirects(fetchedRedirects *[]api.Redirect)
  • func (rm *RedirectManager) HandleOldRedirectsDeletion(fetchedRedirects *[]api.Redirect)
  • func (rm *RedirectManager) PopulateMapsWithDataFromDB()
  • func (rm *RedirectManager) SyncRedirects(redirectsCh <-chan []api.Redirect, errCh <-chan error)
  • func (rm *RedirectManager) UpsertRedirect(r api.Redirect) error
• type Rule

Types

type IndexedRedirects

type IndexedRedirects struct {
	LengthMap   map[int]map[string][]*Rule
	DomainRules []*Rule
	// contains filtered or unexported fields
}

func NewIndexedRedirects

func NewIndexedRedirects() *IndexedRedirects

func (*IndexedRedirects) Delete

func (idx *IndexedRedirects) Delete(pattern, fromDomain string)

func (*IndexedRedirects) IndexRule

func (idx *IndexedRedirects) IndexRule(pattern, fromDomain, target string)

func (*IndexedRedirects) Match

func (idx *IndexedRedirects) Match(url string) (string, bool)

Match matches the incoming requests against the redirect rules

func (*IndexedRedirects) Update

func (idx *IndexedRedirects) Update(pattern, fromDomain, target string)

type Logger

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

func NewLogger

func NewLogger(fileName string, gqlClient *v1.GraphQLClient) *Logger

func (*Logger) LoadLoggedRequests

func (l *Logger) LoadLoggedRequests() error

LoadLoggedRequests loads the requestsMap with data from the .log file

func (*Logger) LogRequest

func (l *Logger) LogRequest(requestURL string) error

LogRequest logs any incoming requests with dates to the .log file

func (*Logger) SendLogs

func (l *Logger) SendLogs()

func (*Logger) SendLogsWeekly

func (l *Logger) SendLogsWeekly()

SendLogsWeekly starts a cron job to send request logs weekly

type RedirectManager

type RedirectManager struct {
	IndexedRedirects *IndexedRedirects
	// contains filtered or unexported fields
}

func NewRedirectManager

func NewRedirectManager(db *sql.DB, gqlClient *api.GraphQLClient) *RedirectManager

func (*RedirectManager) DeleteOldRedirect

func (rm *RedirectManager) DeleteOldRedirect(id string) error

func (*RedirectManager) FetchRedirectsOverChannel

func (rm *RedirectManager) FetchRedirectsOverChannel(redirectsCh chan<- []api.Redirect, errCh chan<- error)

func (*RedirectManager) HandleNewOrUpdatedRedirects

func (rm *RedirectManager) HandleNewOrUpdatedRedirects(fetchedRedirects *[]api.Redirect)

func (*RedirectManager) HandleOldRedirectsDeletion

func (rm *RedirectManager) HandleOldRedirectsDeletion(fetchedRedirects *[]api.Redirect)

func (*RedirectManager) PopulateMapsWithDataFromDB

func (rm *RedirectManager) PopulateMapsWithDataFromDB()

func (*RedirectManager) SyncRedirects

func (rm *RedirectManager) SyncRedirects(redirectsCh <-chan []api.Redirect, errCh <-chan error)

SyncRedirects synchronizes the fetched redirects with the redirects map and the sqlite records

func (*RedirectManager) UpsertRedirect

func (rm *RedirectManager) UpsertRedirect(r api.Redirect) error

type Rule

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