fifos/start.go

   1 package fifos
   2
   3 import (
   4         "path/filepath"
   5
   6         "go.stargrave.org/tofuproxy/caches"
   7 )
   8
   9 func Start(fifos string) {
  10         go logger(LogCert, filepath.Join(fifos, "log-cert"))
  11         go logger(LogDANE, filepath.Join(fifos, "log-dane"))
  12         go logger(LogErr, filepath.Join(fifos, "log-err"))
  13         go logger(LogHTTPAuth, filepath.Join(fifos, "log-http-auth"))
  14         go logger(LogNonOK, filepath.Join(fifos, "log-non-ok"))
  15         go logger(LogOK, filepath.Join(fifos, "log-ok"))
  16         go logger(LogRedir, filepath.Join(fifos, "log-redir"))
  17         go logger(LogReq, filepath.Join(fifos, "log-req"))
  18         go logger(LogTLS, filepath.Join(fifos, "log-tls"))
  19         go logger(LogTLSAuth, filepath.Join(fifos, "log-tls-auth"))
  20         go logger(LogVarious, filepath.Join(fifos, "log-various"))
  21
  22         go listAccepted(filepath.Join(fifos, "list-accepted"))
  23         go listHTTPAuth(filepath.Join(fifos, "list-http-auth"))
  24         go listRejected(filepath.Join(fifos, "list-rejected"))
  25         go listTLSAuth(filepath.Join(fifos, "list-tls-auth"))
  26
  27         go del(
  28                 &caches.AcceptedM, func(host string) { delete(caches.Accepted, host) },
  29                 filepath.Join(fifos, "del-accepted"),
  30         )
  31         go del(
  32                 &caches.HTTPAuthCacheM, func(host string) { delete(caches.HTTPAuthCache, host) },
  33                 filepath.Join(fifos, "del-http-auth"),
  34         )
  35         go del(
  36                 &caches.RejectedM, func(host string) { delete(caches.Rejected, host) },
  37                 filepath.Join(fifos, "del-rejected"),
  38         )
  39         go del(
  40                 &caches.TLSAuthCacheM, func(host string) { delete(caches.TLSAuthCache, host) },
  41                 filepath.Join(fifos, "del-tls-auth"),
  42         )
  43 }