domain

Documentation

Overview

Package domain is a container of all of the domain types and interfaces that are used across multiple packages within the service.

This package is also the container for all domain errors leveraged by the service. Each error here should represent a specific condition that needs to be communicated across interface boundaries.

Generally speaking, this package contains no executable code. All elements are expected to be either pure data containers that have no associated methods or interface definitions that have no corresponding implementations in this package. The notable exception to this are the domain error types which are required to define a corresponding Error() method. Because these errors provide executable code they must also have corresponding tests. Only domain error types are allowed to deviate from the "no executable code" rule.

Index

• type CloudAllAssetsByTimeFetcher
• type CloudAssetByHostnameFetcher
• type CloudAssetByIPFetcher
• type CloudAssetChanges
• type CloudAssetDetails
• type CloudAssetStorer
• type LogFn
• type Logger
• type NetworkChanges
• type NotFoundPartition
  • func (e NotFoundPartition) Error() string
• type Partition
• type PartitionConflict
  • func (e PartitionConflict) Error() string
• type PartitionGenerator
• type PartitionsDeleter
• type PartitionsGetter
• type SchemaMigratorDown
• type SchemaMigratorToVersion
• type SchemaMigratorUp
• type SchemaVersionGetter
• type Stat
• type StatFn
• type StorageMigrator

Types

type CloudAllAssetsByTimeFetcher

type CloudAllAssetsByTimeFetcher interface {
	FetchAll(ctx context.Context, when time.Time, count uint, offset uint, assetType string) ([]CloudAssetDetails, error)
}

CloudAllAssetsByTimeFetcher fetches details for all cloud assets based on limit and optional offset with a given point in time

type CloudAssetByHostnameFetcher

type CloudAssetByHostnameFetcher interface {
	FetchByHostname(ctx context.Context, when time.Time, hostname string) ([]CloudAssetDetails, error)
}

CloudAssetByHostnameFetcher fetches details for a cloud asset with a given hostname at a point in time

type CloudAssetByIPFetcher

type CloudAssetByIPFetcher interface {
	FetchByIP(ctx context.Context, when time.Time, ipAddress string) ([]CloudAssetDetails, error)
}

CloudAssetByIPFetcher fetches details for a cloud asset with a given IP address at a point in time

type CloudAssetChanges

type CloudAssetChanges struct {
	Changes      []NetworkChanges
	ChangeTime   time.Time
	ResourceType string
	AccountID    string
	Region       string
	ARN          string
	Tags         map[string]string
}

CloudAssetChanges represent network changes to an asset and associated metadata

type CloudAssetDetails

type CloudAssetDetails struct {
	PrivateIPAddresses []string
	PublicIPAddresses  []string
	Hostnames          []string
	ResourceType       string
	AccountID          string
	Region             string
	ARN                string
	Tags               map[string]string
}

CloudAssetDetails represent an asset and associated metadata

type CloudAssetStorer

type CloudAssetStorer interface {
	Store(context.Context, CloudAssetChanges) error
}

CloudAssetStorer interface provides functions for inserting cloud assets

type LogFn

type LogFn = runhttp.LogFn

LogFn is the recommended way to extract a logger from the context.

var LoggerFromContext LogFn = runhttp.LoggerFromContext

LoggerFromContext is a concrete implementation of the LogFn interface.

type Logger

type Logger = runhttp.Logger

Logger is the project logger interface.

type NetworkChanges

type NetworkChanges struct {
	PrivateIPAddresses []string
	PublicIPAddresses  []string
	Hostnames          []string
	ChangeType         string
}

NetworkChanges represent changes to an asset's IP addresses or associated host names

type NotFoundPartition

type NotFoundPartition struct {
	Name string
}

NotFoundPartition is used to indicate a request to delete a partition which does not exist in the db

func (NotFoundPartition) Error

func (e NotFoundPartition) Error() string

type Partition

type Partition struct {
	Name      string
	CreatedAt time.Time
	Begin     time.Time
	End       time.Time
	Count     int
}

Partition represents a database partition with the specified time range

type PartitionConflict

type PartitionConflict struct {
	Name string
}

PartitionConflict is used to indicate a partition exists which overlaps with a partition requested to be created

func (PartitionConflict) Error

func (e PartitionConflict) Error() string

type PartitionGenerator

type PartitionGenerator interface {
	GeneratePartition(context.Context, time.Time, int) error
}

PartitionGenerator is used to generate the next time-based partition

type PartitionsDeleter

type PartitionsDeleter interface {
	DeletePartitions(context.Context, string) error
}

PartitionsDeleter is used to drop partitions by name.

type PartitionsGetter

type PartitionsGetter interface {
	GetPartitions(context.Context) ([]Partition, error)
}

PartitionsGetter is used to fetch a list of partitions

type SchemaMigratorDown

type SchemaMigratorDown interface {
	MigrateSchemaDown(ctx context.Context) (uint, error)
}

SchemaMigratorDown is used to migrate database schema to older version

type SchemaMigratorToVersion

type SchemaMigratorToVersion interface {
	MigrateSchemaToVersion(ctx context.Context, version uint) error
}

SchemaMigratorToVersion is used to migrate database schema to specific version

type SchemaMigratorUp

type SchemaMigratorUp interface {
	MigrateSchemaUp(ctx context.Context) (uint, error)
}

SchemaMigratorUp is used to migrate database schema to newer version

type SchemaVersionGetter

type SchemaVersionGetter interface {
	GetSchemaVersion(ctx context.Context) (uint, error)
}

SchemaVersionGetter is used to retrieve the current version of DB schema

type Stat

type Stat = runhttp.Stat

Stat is the project metrics client interface.

type StatFn

type StatFn = runhttp.StatFn

StatFn is the recommended way to extract a metrics client from the context.

var StatFromContext StatFn = runhttp.StatFromContext

StatFromContext is a concrete implementation of the StatFn interface.

type StorageMigrator

type StorageMigrator interface {
	Migrate(version uint) error
	Steps(steps int) error
	Version() (version uint, dirty bool, err error)
}

StorageMigrator presents and abstraction over Database Schema migration