const (
	MaxGetConnTimeout = 10 * time.Second
)

var (
	// ErrClusterClosed returned when requested on a closed cluster.
	ErrClusterClosed = fmt.Errorf("cluster closed")

	// ErrClusterEmpty returned when no connections left in cluster.
	ErrClusterEmpty = fmt.Errorf("cluster empty")
)

type CRUD interface {
	// Insert inserts endpoint to cluster
	Insert(ctx context.Context, endpoint endpoint.Endpoint, opts ...crudOption) conn.Conn

	// Update updates endpoint in cluster
	Update(ctx context.Context, endpoint endpoint.Endpoint, opts ...crudOption) conn.Conn

	// Remove removes endpoint from cluster
	Remove(ctx context.Context, endpoint endpoint.Endpoint, opts ...crudOption) conn.Conn

	// Get gets conn from cluster
	Get(ctx context.Context, opts ...crudOption) (cc conn.Conn, err error)
}

type CRUDExplorerLocker interface {
	CRUD
	Explorer
	Locker
}

type Cluster interface {
	closer.Closer
	CRUD
	Explorer
	Locker
	conn.PoolGetter
	conn.Pessimizer
}

type Endpoint interface {
	NodeID() uint32
}

type Explorer interface {
	SetExplorer(repeater repeater.Repeater)
	Force()
}

type Locker interface {
	Lock()
	Unlock()
}