archivingcache

package

Go to main page

Versions in this module

v0

v0.4.0

Feb 14, 2024

v0.3.2

Aug 20, 2021

v0.3.1

May 10, 2021

Changes in this version

type Cache

+ func (c *Cache) Reset() error

type ContentWriterClient

+ func (c *ContentWriterClient) Connect() error

+ func (c *ContentWriterClient) WriteRecord(payload []byte, fetchStart time.Time, requestedHost string, proxyAddr string, ...) (*contentwriterV1.WriteReply, error)

+ type LogWriterClient struct

+ func NewLogWriterClient(opts ...serviceconnections.ConnectionOption) *LogWriterClient

+ func (l *LogWriterClient) Connect() error

+ func (l *LogWriterClient) WriteCrawlLog(record *contentwriterV1.WriteResponseMeta_RecordMeta, size int, ...) error

v0.3.0

Apr 21, 2021

Changes in this version

type ArchivingCache

+ func (a *ArchivingCache) WriteCrawlLog(payload []byte, record *contentwriterV1.WriteResponseMeta_RecordMeta, ...) error

+ type LogServiceMock struct

+ CrawlLogs []*logV1.CrawlLog

+ func NewLogServiceMock(port int) *LogServiceMock

+ func (s *LogServiceMock) Close()

+ func (s *LogServiceMock) WriteCrawlLog(stream logV1.Log_WriteCrawlLogServer) error

v0.2.8

Mar 25, 2021

Changes in this version

+ var CacheHits = promauto.NewCounterVec(prometheus.CounterOpts{ ... }, []string{ ... })

+ var CacheMisses = promauto.NewCounterVec(prometheus.CounterOpts{ ... }, []string{ ... })

+ var CacheSize = promauto.NewGaugeVec(prometheus.GaugeOpts{ ... }, []string{ ... })

+ func NewDbConnection(dbHost string, dbPort int, dbUser string, dbPassword string, dbName string) *database

type ArchivingCache

+ func (a *ArchivingCache) Ready() bool

type Cache

+ func (c *Cache) Len() int

+ func (c *Cache) Set(key string, entry *CacheEntry) error

type CacheEntry

+ CollectionIds []string

+ Msg *dns.Msg

+ ProxyAddr string

+ type ContentWriterClient struct

+ func NewContentWriterClient(contentWriterHost string, contentWriterPort int) *ContentWriterClient

+ type ContentWriterMock struct

+ Cancel string

+ Header *contentwriterV1.Data

+ Meta *contentwriterV1.WriteRequestMeta

+ Payload *contentwriterV1.Data

+ func NewContentWriterServerMock(port int) *ContentWriterMock

+ func (s *ContentWriterMock) Close()

+ func (s *ContentWriterMock) Delete(ctx context.Context, in *empty.Empty) (*empty.Empty, error)

+ func (s *ContentWriterMock) Flush(ctx context.Context, in *empty.Empty) (*empty.Empty, error)

+ func (s *ContentWriterMock) Write(stream contentwriterV1.ContentWriter_WriteServer) error

v0.2.2

Jan 30, 2019

v0.2.1

Jan 29, 2019

v0.2.0

Jan 17, 2019

Changes in this version

+ const Denial

+ const Success

+ type ArchivingCache struct

+ Connection *Connection

+ Next plugin.Handler

+ UpstreamIP string

+ UpstreamPort string

+ func NewArchivingCache(eviction time.Duration, maxSizeMb int, UpstreamIP string, UpstreamPort string, ...) (*ArchivingCache, error)

+ func (a *ArchivingCache) Close()

+ func (a *ArchivingCache) Name() string

+ func (a *ArchivingCache) OnShutdown() error

+ func (a *ArchivingCache) OnStartup() (err error)

+ func (a *ArchivingCache) ServeDNS(ctx context.Context, w dns.ResponseWriter, r *dns.Msg) (int, error)

+ type Cache struct

+ func NewCache(lifeWindow time.Duration, maxSizeMb int) (*Cache, error)

+ func (c *Cache) Get(key string) (*CacheEntry, error)

+ func (c *Cache) Put(key string, server string, cacheEntry *CacheEntry) error

+ type CacheEntry struct

+ func (ce *CacheEntry) AddCollectionId(collectionId string) []string

+ func (ce *CacheEntry) HasCollectionId(collectionId string) bool

+ func (ce *CacheEntry) String() string

+ type Connection struct

+ func NewConnection(dbHost string, dbPort int, dbUser string, dbPassword string, dbName string, ...) *Connection

+ type Recorder struct

+ Err error

+ FetchDurationMs int64

+ FetchStart time.Time

+ Msg *dns.Msg

+ Rcode int

+ RequestedHost string

+ UpstreamIP string

+ func NewRecorder(a *ArchivingCache, key string, server string, connection *Connection, ...) *Recorder

+ func (rec *Recorder) Close() error

+ func (rec *Recorder) Hijack()

+ func (rec *Recorder) LocalAddr() net.Addr

+ func (rec *Recorder) NextPlugin(ctx context.Context, request *dns.Msg)

+ func (rec *Recorder) RemoteAddr() net.Addr

+ func (rec *Recorder) SetMsg(res *dns.Msg) error

+ func (rec *Recorder) TsigStatus() error

+ func (rec *Recorder) TsigTimersOnly(b bool)

+ func (rec *Recorder) Write(b []byte) (int, error)

+ func (rec *Recorder) WriteMsg(res *dns.Msg) error

+ func (rec *Recorder) WriteRecordedMessage(rw dns.ResponseWriter, request *dns.Msg, shared bool) (int, error)

+ type Server struct

+ Cancel string

+ Header *contentwriterV1.Data

+ Meta *contentwriterV1.WriteRequestMeta

+ Payload *contentwriterV1.Data

+ func NewCWServer(port int) *Server

+ func (s *Server) Close()

+ func (s *Server) Delete(ctx context.Context, in *empty.Empty) (*empty.Empty, error)

+ func (s *Server) Flush(ctx context.Context, in *empty.Empty) (*empty.Empty, error)

+ func (s *Server) Write(stream contentwriterV1.ContentWriter_WriteServer) error

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL