servers

Documentation

Index

• type Repository
  • func New(clock clockwork.Clock) *Repository
  • func (r *Repository) Add(ctx context.Context, svr server.Server, onConflict func(*server.Server) bool) (server.Server, error)
  • func (r *Repository) AddOrUpdate(ctx context.Context, svr server.Server, onConflictDo func(*server.Server)) (server.Server, error)
  • func (r *Repository) Count(context.Context) (int, error)
  • func (r *Repository) CountByStatus(_ context.Context) (map[ds.DiscoveryStatus]int, error)
  • func (r *Repository) Filter(_ context.Context, fs filterset.FilterSet) ([]server.Server, error)
  • func (r *Repository) Get(_ context.Context, addr addr.Addr) (server.Server, error)
  • func (r *Repository) Remove(_ context.Context, svr server.Server, onConflict func(*server.Server) bool) error
  • func (r *Repository) Update(ctx context.Context, svr server.Server, onConflict func(*server.Server) bool) (server.Server, error)

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

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)