server

Documentation

Index

• type Service
  • func NewService(repo servers.Repository) *Service
  • func (s *Service) Create(ctx context.Context, svr servers.Server, onConflict func(*servers.Server) bool) (servers.Server, error)
  • func (s *Service) CreateOrUpdate(ctx context.Context, svr servers.Server, onConflictDo func(*servers.Server)) (servers.Server, error)
  • func (s *Service) FilterRecent(ctx context.Context, recentness time.Duration, q query.Query, ...) ([]servers.Server, error)
  • func (s *Service) Get(ctx context.Context, address addr.Addr) (servers.Server, error)
  • func (s *Service) Update(ctx context.Context, svr servers.Server, onConflict func(*servers.Server) bool) (servers.Server, error)

Types

type Service

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

func NewService

func NewService(repo servers.Repository) *Service

func (*Service) Create

func (s *Service) Create(
	ctx context.Context,
	svr servers.Server,
	onConflict func(*servers.Server) bool,
) (servers.Server, error)

func (*Service) CreateOrUpdate

func (s *Service) CreateOrUpdate(
	ctx context.Context,
	svr servers.Server,
	onConflictDo func(*servers.Server),
) (servers.Server, error)

func (*Service) FilterRecent

func (s *Service) FilterRecent(
	ctx context.Context,
	recentness time.Duration,
	q query.Query,
	withStatus ds.DiscoveryStatus,
) ([]servers.Server, error)

func (*Service) Get

func (s *Service) Get(ctx context.Context, address addr.Addr) (servers.Server, error)

func (*Service) Update

func (s *Service) Update(
	ctx context.Context,
	svr servers.Server,
	onConflict func(*servers.Server) bool,
) (servers.Server, error)