storage

Documentation

Index

• Constants
• type Backend
  • func NewBackend(connStr string) (Backend, error)
• type DB
  • func NewDB(connStr string) (*DB, error)
  • func (db *DB) ActiveTests(ctx context.Context, timeout time.Duration) (int64, error)
  • func (db *DB) Close()
  • func (db *DB) FinishTest(ctx context.Context, t *Test) error
  • func (db *DB) InsertTest(ctx context.Context, id uuid.UUID) error
  • func (db *DB) InsertTestResult(ctx context.Context, t *Test, resultType string, addr string, ptr *string) error
  • func (db *DB) PruneTestResults(ctx context.Context) (int64, error)
  • func (db *DB) Test(ctx context.Context, id uuid.UUID) (*Test, error)
  • func (db *DB) TestResults(ctx context.Context, t *Test) ([]*TestResult, error)
• type Memory
  • func NewMemory() *Memory
  • func (m *Memory) ActiveTests(ctx context.Context, timeout time.Duration) (int64, error)
  • func (m *Memory) Close()
  • func (m *Memory) FinishTest(ctx context.Context, t *Test) error
  • func (m *Memory) InsertTest(ctx context.Context, id uuid.UUID) error
  • func (m *Memory) InsertTestResult(ctx context.Context, t *Test, resultType string, addr string, ptr *string) error
  • func (m *Memory) PruneTestResults(ctx context.Context) (int64, error)
  • func (m *Memory) Test(ctx context.Context, id uuid.UUID) (*Test, error)
  • func (m *Memory) TestResults(ctx context.Context, t *Test) ([]*TestResult, error)
• type Test
  • func (t *Test) Done(timeout time.Duration) bool
  • func (t *Test) TimedOut(d time.Duration) bool
• type TestResult
  • func (r *TestResult) Color() string

Constants

const (
	TestResultDnsQuery   = "recv_dns_query"
	TestResultLdapBind   = "recv_ldap_bind"
	TestResultLdapSearch = "recv_ldap_search"
	TestResultHttpGet    = "recv_http_get"
)

Types

type Backend

type Backend interface {
	Close()
	Test(ctx context.Context, id uuid.UUID) (*Test, error)
	InsertTest(ctx context.Context, id uuid.UUID) error
	InsertTestResult(ctx context.Context, t *Test, resultType string, addr string, ptr *string) error
	TestResults(ctx context.Context, t *Test) ([]*TestResult, error)
	PruneTestResults(ctx context.Context) (int64, error)
	FinishTest(ctx context.Context, t *Test) error
	ActiveTests(ctx context.Context, timeout time.Duration) (int64, error)
}

func NewBackend

func NewBackend(connStr string) (Backend, error)

type DB

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

func NewDB

func NewDB(connStr string) (*DB, error)

func (*DB) ActiveTests

func (db *DB) ActiveTests(ctx context.Context, timeout time.Duration) (int64, error)

func (*DB) Close

func (db *DB) Close()

func (*DB) FinishTest

func (db *DB) FinishTest(ctx context.Context, t *Test) error

func (*DB) InsertTest

func (db *DB) InsertTest(ctx context.Context, id uuid.UUID) error

func (*DB) InsertTestResult

func (db *DB) InsertTestResult(ctx context.Context, t *Test, resultType string, addr string, ptr *string) error

func (*DB) PruneTestResults

func (db *DB) PruneTestResults(ctx context.Context) (int64, error)

func (*DB) Test

func (db *DB) Test(ctx context.Context, id uuid.UUID) (*Test, error)

func (*DB) TestResults

func (db *DB) TestResults(ctx context.Context, t *Test) ([]*TestResult, error)

type Memory

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

func NewMemory

func NewMemory() *Memory

func (*Memory) ActiveTests

func (m *Memory) ActiveTests(ctx context.Context, timeout time.Duration) (int64, error)

func (*Memory) Close

func (m *Memory) Close()

func (*Memory) FinishTest

func (m *Memory) FinishTest(ctx context.Context, t *Test) error

func (*Memory) InsertTest

func (m *Memory) InsertTest(ctx context.Context, id uuid.UUID) error

func (*Memory) InsertTestResult

func (m *Memory) InsertTestResult(ctx context.Context, t *Test, resultType string, addr string, ptr *string) error

func (*Memory) PruneTestResults

func (m *Memory) PruneTestResults(ctx context.Context) (int64, error)

func (*Memory) Test

func (m *Memory) Test(ctx context.Context, id uuid.UUID) (*Test, error)

func (*Memory) TestResults

func (m *Memory) TestResults(ctx context.Context, t *Test) ([]*TestResult, error)

type Test

type Test struct {
	ID       uuid.UUID  `db:"id"`
	Created  *time.Time `db:"created"`
	Finished *time.Time `db:"finished"`
}

func (*Test) Done

func (t *Test) Done(timeout time.Duration) bool

func (*Test) TimedOut

func (t *Test) TimedOut(d time.Duration) bool

type TestResult

type TestResult struct {
	TestID  uuid.UUID  `db:"test_id"`
	Created *time.Time `db:"created"`
	Type    string     `db:type`
	Addr    *string    `db:ip`
	Ptr     *string    `db:ptr`
}

func (*TestResult) Color

func (r *TestResult) Color() string