servers

Documentation

Index

• type LockOpts
• type Repository
  • func New(client *redis.Client, locker *redislock.Manager, c clockwork.Clock) *Repository
  • func (r *Repository) Add(ctx context.Context, svr server.Server, onConflict func(*server.Server) bool) (server.Server, error)
  • func (r *Repository) Count(ctx context.Context) (int, error)
  • func (r *Repository) CountByStatus(ctx context.Context) (map[ds.DiscoveryStatus]int, error)
  • func (r *Repository) Filter(ctx context.Context, fs filterset.ServerFilterSet) ([]server.Server, error)
  • func (r *Repository) Get(ctx context.Context, addr addr.Addr) (server.Server, error)
  • func (r *Repository) Remove(ctx 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 LockOpts

type LockOpts struct {
	LeaseDuration time.Duration
	RetryBackoff  time.Duration
	MaxAttempts   int
}

type Repository

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

func New

func New(client *redis.Client, locker *redislock.Manager, c 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) Count

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

func (*Repository) CountByStatus

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

func (*Repository) Filter

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

func (*Repository) Get

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

func (*Repository) Remove

func (r *Repository) Remove(
	ctx 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)