servers

package
v0.8.0 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Mar 27, 2024 License: MIT Imports: 11 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type Repository

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

func New

func New(clock clockwork.Clock) *Repository

func (*Repository) Add

func (r *Repository) Add(
	ctx context.Context,
	svr server.Server,
	onConflict func(*server.Server) bool,
) (server.Server, error)

func (*Repository) AddOrUpdate added in v0.7.0

func (r *Repository) AddOrUpdate(
	ctx context.Context,
	svr server.Server,
	onConflictDo func(*server.Server),
) (server.Server, error)

func (*Repository) Count

func (r *Repository) Count(context.Context) (int, error)

func (*Repository) CountByStatus

func (r *Repository) CountByStatus(_ context.Context) (map[ds.DiscoveryStatus]int, error)

func (*Repository) Filter

func (r *Repository) Filter(
	_ context.Context,
	fs filterset.FilterSet,
) ([]server.Server, error)

func (*Repository) Get

func (r *Repository) Get(_ context.Context, addr addr.Addr) (server.Server, error)

func (*Repository) Remove

func (r *Repository) Remove(
	_ context.Context,
	svr server.Server,
	onConflict func(*server.Server) bool,
) error

func (*Repository) Update

func (r *Repository) Update(
	ctx context.Context,
	svr server.Server,
	onConflict func(*server.Server) bool,
) (server.Server, error)

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL