dnsmdb

Documentation

Overview

Package dnsmdb implements dnsutil.Archive using mongodb backend.

This package is a work in progress and makes no API stability promises.

Index

• Constants
• func Builder() archive.BuildServiceFn
• type Archiver
  • func New(id string, session *mgo.Session, db string, opt ...Option) *Archiver
  • func (a *Archiver) Class() string
  • func (a *Archiver) ID() string
  • func (a *Archiver) Implements() []archive.API
  • func (a *Archiver) Ping() error
  • func (a *Archiver) SaveResolv(ctx context.Context, r *dnsutil.ResolvData) (string, error)
  • func (a *Archiver) Shutdown()
  • func (a *Archiver) Start() error
• type Option
  • func CloseSession(b bool) Option
  • func SetLogger(l yalogi.Logger) Option
  • func SetPrefix(s string) Option

Constants

const (
	DefaultDBName         = "luidsdb"
	DefaultResolvBulkSize = 1024
	DefaultSyncSeconds    = 5
)

Default values.

const (
	ResolvColName = "resolvs"
)

Collection names.

const ServiceClass = "dnsmdb"

ServiceClass registered.

Functions

func Builder

func Builder() archive.BuildServiceFn

Builder returns a builder function.

Types

type Archiver

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

Archiver implements dns archive backend using a mongo database.

func New

func New(id string, session *mgo.Session, db string, opt ...Option) *Archiver

New creates a new storage.

func (*Archiver) Class

func (a *Archiver) Class() string

Class implements archive.Service interface.

func (*Archiver) ID

func (a *Archiver) ID() string

ID implements archive.Service interface.

func (*Archiver) Implements

func (a *Archiver) Implements() []archive.API

Implements implements archive.Service interface.

func (*Archiver) Ping

func (a *Archiver) Ping() error

Ping tests the connection with the storage.

func (*Archiver) SaveResolv

func (a *Archiver) SaveResolv(ctx context.Context, r *dnsutil.ResolvData) (string, error)

SaveResolv implements dnsutil.Archiver interface.

func (*Archiver) Shutdown

func (a *Archiver) Shutdown()

Shutdown closes the conection.

func (*Archiver) Start

func (a *Archiver) Start() error

Start the archiver.

type Option

type Option func(*options)

Option encapsules options.

func CloseSession

func CloseSession(b bool) Option

CloseSession option allows close mongo session on shutdown.

func SetLogger

func SetLogger(l yalogi.Logger) Option

SetLogger option allows set a custom logger.

func SetPrefix

func SetPrefix(s string) Option

SetPrefix option allows set a prefix to collection.