repositories

Documentation

Index

• Variables
• func ServerOnConflictIgnore(_ *server.Server) bool
• type InstanceRepository
• type ProbeRepository
• type ServerRepository

Variables

var (
	ErrServerNotFound = errors.New("the requested server was not found")
	ErrServerExists   = errors.New("server already exists")
)

var ErrInstanceNotFound = errors.New("the requested instance was not found")

var ErrProbeQueueIsEmpty = errors.New("queue is empty")

var NC = time.Time{} // no constraint

Functions

func ServerOnConflictIgnore

func ServerOnConflictIgnore(_ *server.Server) bool

Types

type InstanceRepository

type InstanceRepository interface {
	Add(context.Context, instance.Instance) error
	Get(context.Context, instance.Identifier) (instance.Instance, error)
	Remove(context.Context, instance.Identifier) error
	Clear(context.Context, filterset.InstanceFilterSet) (int, error)
	Count(context.Context) (int, error)
}

type ProbeRepository

type ProbeRepository interface {
	Add(context.Context, probe.Probe) error
	AddBetween(context.Context, probe.Probe, time.Time, time.Time) error
	Pop(context.Context) (probe.Probe, error)
	Peek(context.Context) (probe.Probe, error)
	PopMany(context.Context, int) ([]probe.Probe, int, error)
	Count(context.Context) (int, error)
}

type ServerRepository

type ServerRepository interface {
	Get(ctx context.Context, addr addr.Addr) (server.Server, error)
	Add(ctx context.Context, server server.Server, onConflict func(*server.Server) bool) (server.Server, error)
	Update(ctx context.Context, server server.Server, onConflict func(*server.Server) bool) (server.Server, error)
	AddOrUpdate(ctx context.Context, server server.Server, onConflict func(*server.Server)) (server.Server, error)
	Remove(ctx context.Context, server server.Server, onConflict func(*server.Server) bool) error
	Filter(ctx context.Context, fs filterset.ServerFilterSet) ([]server.Server, error)
	Count(ctx context.Context) (int, error)
	CountByStatus(ctx context.Context) (map[ds.DiscoveryStatus]int, error)
}