storage

Documentation

Index

• Constants
• type EmptyStorageHandler
  • func (esh *EmptyStorageHandler) Close() (err error)
  • func (esh *EmptyStorageHandler) Open() (err error)
  • func (esh *EmptyStorageHandler) Store(data interface{}) (err error)
• type MongoClient
• type MongoClientWrapper
  • func (mcw *MongoClientWrapper) Database(name string, opts ...*options.DatabaseOptions) MongoDatabase
  • func (mcw *MongoClientWrapper) Disconnect(ctx context.Context) error
• type MongoCollection
• type MongoCollectionWrapper
  • func (mcw *MongoCollectionWrapper) InsertOne(ctx context.Context, document interface{}, opts ...*options.InsertOneOptions) (*mongo.InsertOneResult, error)
• type MongoConnect
• type MongoDatabase
• type MongoDatabaseWrapper
  • func (mdw *MongoDatabaseWrapper) Collection(name string) MongoCollection
• type MongoStorageHandler
  • func NewDefaultMongoStorageHandler(ctx context.Context, collectionName string) *MongoStorageHandler
  • func (msh *MongoStorageHandler) Close() (err error)
  • func (msh *MongoStorageHandler) Open() (err error)
  • func (msh *MongoStorageHandler) Store(data interface{}) (err error)
• type StorageHandler

Constants

const DEFAULT_CERTIFICATE_COLLECTION = "certificate-scans"

const DEFAULT_DATABASE = "doe"

const DEFAULT_DDR_COLLECTION = "ddr-scans"

const DEFAULT_DOH_COLLECTION = "doh-scans"

const DEFAULT_DOQ_COLLECTION = "doq-scans"

const DEFAULT_DOT_COLLECTION = "dot-scans"

const DEFAULT_MONGO_URI = "mongodb://root:example@localhost:27017/"

const DEFAULT_PTR_COLLECTION = "ptr-scans"

const ENV_MONGO_URI = "MONGO_USERNAME"

Types

type EmptyStorageHandler

type EmptyStorageHandler struct {
	StorageHandler
}

func (*EmptyStorageHandler) Close

func (esh *EmptyStorageHandler) Close() (err error)

func (*EmptyStorageHandler) Open

func (esh *EmptyStorageHandler) Open() (err error)

func (*EmptyStorageHandler) Store

func (esh *EmptyStorageHandler) Store(data interface{}) (err error)

type MongoClient

type MongoClient interface {
	Database(name string, opts ...*options.DatabaseOptions) MongoDatabase
	Disconnect(ctx context.Context) error
}

type MongoClientWrapper

type MongoClientWrapper struct {
	Client *mongo.Client
}

func (*MongoClientWrapper) Database

func (mcw *MongoClientWrapper) Database(name string, opts ...*options.DatabaseOptions) MongoDatabase

func (*MongoClientWrapper) Disconnect

func (mcw *MongoClientWrapper) Disconnect(ctx context.Context) error

type MongoCollection

type MongoCollection interface {
	InsertOne(ctx context.Context, document interface{}, opts ...*options.InsertOneOptions) (*mongo.InsertOneResult, error)
}

type MongoCollectionWrapper

type MongoCollectionWrapper struct {
	Collection MongoCollection
}

func (*MongoCollectionWrapper) InsertOne

func (mcw *MongoCollectionWrapper) InsertOne(ctx context.Context, document interface{}, opts ...*options.InsertOneOptions) (*mongo.InsertOneResult, error)

type MongoConnect

type MongoConnect func(ctx context.Context, opts ...*options.ClientOptions) (MongoClient, error)

type MongoDatabase

type MongoDatabase interface {
	Collection(name string) MongoCollection
}

type MongoDatabaseWrapper

type MongoDatabaseWrapper struct {
	Database *mongo.Database
}

func (*MongoDatabaseWrapper) Collection

func (mdw *MongoDatabaseWrapper) Collection(name string) MongoCollection

type MongoStorageHandler

type MongoStorageHandler struct {
	StorageHandler

	Connect MongoConnect
	Client  MongoClient

	DatabaseName   string
	CollectionName string
}

func NewDefaultMongoStorageHandler

func NewDefaultMongoStorageHandler(ctx context.Context, collectionName string) *MongoStorageHandler

func (*MongoStorageHandler) Close

func (msh *MongoStorageHandler) Close() (err error)

func (*MongoStorageHandler) Open

func (msh *MongoStorageHandler) Open() (err error)

func (*MongoStorageHandler) Store

func (msh *MongoStorageHandler) Store(data interface{}) (err error)

type StorageHandler

type StorageHandler interface {
	Store(data interface{}) (err error)
	Open() (err error)
	Close() (err error)
}